Commit de85933c authored by Anastasios Poimenidis's avatar Anastasios Poimenidis
Browse files

fix: rename service monitor channel name to service-monitor-result

parent 0e493e43

src/main/java/org/etsi/osl/hypo/api/tmf/services/inventory/api/kafka/incoming/ServiceInventoryKafkaListener.java

+2 −2
Original line number Diff line number Diff line
@@ -89,12 +89,12 @@ public class ServiceInventoryKafkaListener { 
    }



    @WithSpan("ServiceInventoryKafkaListener.receiveServiceMonitoringRequest")

    @Incoming("service-monitor-request")

    @Incoming("service-monitor-result")

    @Blocking

    public void receiveServiceMonitorRequest(ServiceMonitorRequest serviceMonitorRequest) {

        logger.debugf(

                "Received event message for service monitor: %s in channel %s",

                serviceMonitorRequest, "service-monitor-request");

                serviceMonitorRequest, "service-monitor-result");

        serviceInventoryService.updateServiceWithMonitorInfo(serviceMonitorRequest);

    }

}

src/main/resources/application.properties

+4 −4
Original line number Diff line number Diff line
@@ -117,10 +117,10 @@ mp.messaging.incoming.tmf-service-dashboard-update.value.deserializer=org.etsi.o 
#mp.messaging.incoming.tmf-service-dashboard-update.fail-on-deserialization-failure=true



# incoming channel for Service monitor events

mp.messaging.incoming.service-monitor-request.connector=smallrye-kafka

mp.messaging.incoming.service-monitor-request.topic=service-monitor-request

mp.messaging.incoming.service-monitor-request.value.deserializer=org.etsi.osl.hypo.api.tmf.services.inventory.api.kafka.incoming.ServiceMonitorRequestDeserializer

#mp.messaging.incoming.tmf-service-dashboard-update.fail-on-deserialization-failure=true

mp.messaging.incoming.service-monitor-result.connector=smallrye-kafka

mp.messaging.incoming.service-monitor-result.topic=service-monitor-result

mp.messaging.incoming.service-monitor-result.value.deserializer=org.etsi.osl.hypo.api.tmf.services.inventory.api.kafka.incoming.ServiceMonitorRequestDeserializer

#mp.messaging.incoming.service-monitor-result.fail-on-deserialization-failure=true



# incoming channel for deletion of Grafana dashboard data

mp.messaging.incoming.tmf-service-dashboard-delete.connector=smallrye-kafka