Add logging

Author: thjarvin

src/main/java/fi/hsl/transitdata/stopestimates/MessageHandler.java

@@ -55,15 +55,17 @@ private void ack(MessageId received) {
 
     private void sendPulsarMessage(MessageId received, InternalMessages.StopEstimate estimate, long timestamp, String key) {
 
-        String tripId = estimate.getTripInfo().getTripId();
-        log.info("TripId: {}", tripId);
+        String routeId = estimate.getTripInfo().getRouteId();
+        if (routeId.contains("31M")) {
+            log.info("RouteId: {}", routeId);
+        }
 
         producer.newMessage()
                 .key(key)
                 .eventTime(timestamp)
                 .property(TransitdataProperties.KEY_PROTOBUF_SCHEMA, ProtobufSchema.InternalMessagesStopEstimate.toString())
                 .property(TransitdataProperties.KEY_SCHEMA_VERSION, Integer.toString(estimate.getSchemaVersion()))
-                .property(TransitdataProperties.KEY_DVJ_ID, tripId) // TODO remove once TripUpdateProcessor won't need it anymore
+                .property(TransitdataProperties.KEY_DVJ_ID, estimate.getTripInfo().getTripId()) // TODO remove once TripUpdateProcessor won't need it anymore
                 .value(estimate.toByteArray())
                 .sendAsync()
                 .whenComplete((MessageId id, Throwable t) -> {