Add logging

Author: thjarvin

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

@@ -54,13 +54,18 @@ private void ack(MessageId received) {
     }
 
     private void sendPulsarMessage(MessageId received, InternalMessages.StopEstimate estimate, long timestamp, String key) {
-
+        
+        String tripId = estimate.getTripInfo().getTripId();
+        if (tripId.startsWith("HSL:31M")) {
+            log.info("Metro trip. TripId: {}", tripId);
+        }
+        
         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, estimate.getTripInfo().getTripId()) // TODO remove once TripUpdateProcessor won't need it anymore
+                .property(TransitdataProperties.KEY_DVJ_ID, tripId) // TODO remove once TripUpdateProcessor won't need it anymore
                 .value(estimate.toByteArray())
                 .sendAsync()
                 .whenComplete((MessageId id, Throwable t) -> {