diff --git a/ems-core/broker-cep/src/main/java/gr/iccs/imu/ems/brokercep/broker/interceptor/LogMessageUpdateInterceptor.java b/ems-core/broker-cep/src/main/java/gr/iccs/imu/ems/brokercep/broker/interceptor/LogMessageUpdateInterceptor.java index f2aa1b1..3b493bb 100644 --- a/ems-core/broker-cep/src/main/java/gr/iccs/imu/ems/brokercep/broker/interceptor/LogMessageUpdateInterceptor.java +++ b/ems-core/broker-cep/src/main/java/gr/iccs/imu/ems/brokercep/broker/interceptor/LogMessageUpdateInterceptor.java @@ -27,7 +27,8 @@ public class LogMessageUpdateInterceptor extends AbstractMessageInterceptor { public void initialized() { this.eventRecorder = applicationContext.getBean(BrokerConfig.class).getEventRecorder(); log.debug("LogMessageUpdateInterceptor: Enabled: {}", eventRecorder!=null); - eventRecorder.startRecording(); + if (eventRecorder!=null) + eventRecorder.startRecording(); } @Override