diff --git a/pom.xml b/pom.xml index f73d3b2..bfc8fd4 100644 --- a/pom.xml +++ b/pom.xml @@ -7,7 +7,7 @@ UTF-8 - 1.5.4 + 1.6.1 diff --git a/src/main/java/fi/hsl/transitlog/hfp/persisthfpdata/DomainMappingWriter.java b/src/main/java/fi/hsl/transitlog/hfp/persisthfpdata/DomainMappingWriter.java index 4934d71..5212adf 100644 --- a/src/main/java/fi/hsl/transitlog/hfp/persisthfpdata/DomainMappingWriter.java +++ b/src/main/java/fi/hsl/transitlog/hfp/persisthfpdata/DomainMappingWriter.java @@ -82,7 +82,12 @@ void process(MessageId msgId, Hfp.Data data) throws IOException, ParseException event = eventFactory.createVehiclePositionEvent(data.getTopic(), data.getPayload()); break; case deadrun: - event = eventFactory.createUnsignedEvent(data.getTopic(), data.getPayload()); + try { + event = eventFactory.createUnsignedEvent(data.getTopic(), data.getPayload()); + } catch (Exception e) { + log.error("UnsignedEvent error. Topic: {}, Payload: {}, Error: {}", data.getTopic(), data.getPayload(), e.getMessage(), e); + throw e; + } break; default: if (data.getTopic().getJourneyType() != Hfp.Topic.JourneyType.signoff) {