diff --git a/slo-violation-detector/src/main/java/slo_violation_detector_engine/detector/DetectorSubcomponent.java b/slo-violation-detector/src/main/java/slo_violation_detector_engine/detector/DetectorSubcomponent.java index 73d7d2d..4b776b9 100644 --- a/slo-violation-detector/src/main/java/slo_violation_detector_engine/detector/DetectorSubcomponent.java +++ b/slo-violation-detector/src/main/java/slo_violation_detector_engine/detector/DetectorSubcomponent.java @@ -63,7 +63,7 @@ public class DetectorSubcomponent extends SLOViolationDetectorSubcomponent { detector_name = "detector_"+application_name+"_"+current_detector_id; } for (String metric_string : unbounded_metric_strings) { - subcomponent_state.getMonitoring_attributes_bounds_representation().put(metric_string.split(";")[0], metric_string.split(";", 2)[1]); //TODO delete once this information is successfully received from the AMQP broker + subcomponent_state.getMonitoring_attributes_bounds_representation().put(metric_string.split(";")[0], metric_string.split(";", 2)[1]); //TODO delete once this information is successfully received from the AMQP broker - this is alternative functionality to receiving the metrics list containing the metric boundaries } if (characterized_thread_run_mode.equals(attached)) { DetectorSubcomponentUtilities.run_slo_violation_detection_engine(this); diff --git a/slo-violation-detector/src/main/java/slo_violation_detector_engine/director/DirectorSubcomponent.java b/slo-violation-detector/src/main/java/slo_violation_detector_engine/director/DirectorSubcomponent.java index 5dcd7f7..8b6ec9c 100644 --- a/slo-violation-detector/src/main/java/slo_violation_detector_engine/director/DirectorSubcomponent.java +++ b/slo-violation-detector/src/main/java/slo_violation_detector_engine/director/DirectorSubcomponent.java @@ -117,7 +117,7 @@ public class DirectorSubcomponent extends SLOViolationDetectorSubcomponent { BrokerSubscriber device_lost_subscriber = new BrokerSubscriber(topic_for_lost_device_announcement, broker_ip, broker_port, broker_username, broker_password, amq_library_configuration_location,EMPTY); BiFunction device_lost_subscriber_function = (broker_details, message) -> { - BrokerPublisher persistent_publisher = new BrokerPublisher(topic_for_severity_announcement, broker_ip, broker_port, broker_username, broker_password, amq_library_configuration_location); + BrokerPublisher persistent_publisher = new BrokerPublisher(topic_for_severity_announcement, broker_ip, broker_port, broker_username, broker_password, amq_library_configuration_location, true); Clock clock = Clock.systemUTC(); Long current_time_seconds = (long) Math.floor(clock.millis()/1000.0); diff --git a/slo-violation-detector/src/main/resources/application.properties b/slo-violation-detector/src/main/resources/application.properties index 1f29ada..7089a15 100644 --- a/slo-violation-detector/src/main/resources/application.properties +++ b/slo-violation-detector/src/main/resources/application.properties @@ -1,4 +1,5 @@ spring.profiles.active=production spring.mvc.view.prefix=/src/main/webapp/WEB-INF/jsp/ spring.mvc.view.suffix=.jsp -logging.level.org.springframework.web.servlet.view.InternalResourceViewResolver=DEBUG \ No newline at end of file +logging.level.org.springframework.web.servlet.view.InternalResourceViewResolver=DEBUG +server.port: 8010 \ No newline at end of file