Some cleaning

SNMP_Pipeline/SnmpReciever/src/main/resources/application.properties

@@ -2,7 +2,7 @@ server.port = 0
 spring.kafka.bootstrap-servers=http://172.29.3.220:9092
 spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
 spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
-spring.listener.address=localhost/1625
+spring.listener.address=192.168.27.227/1625
 spring.listener.threads=20
 spring.listener.community=public
 spring.application.name=TRAP-LISTENER-SERVICE

SNMP_Pipeline/Web-Application/src/main/java/com/example/WebApplication/handlers/SseEmitters.java

@@ -27,7 +27,6 @@ public class SseEmitters {
     public void send(Object obj) {
         List<SseEmitter> failedEmitters = new ArrayList<>();
         this.emitters.forEach(emitter -> {
-            System.out.println("Kill me");
             try {
                 emitter.send(obj);
             } catch (Exception e) {

SNMP_Pipeline/Web-Application/src/main/java/com/example/WebApplication/services/RethinkDBService.java

@@ -74,11 +74,14 @@ public class RethinkDBService{
         singleThreadExecutor.execute(() -> {
             try {
                 Connection connection = connectionFactory.getConnection();
-                Cursor<RethinkChange> changeCursor = r.db(connectionFactory.getDbName()).table(connectionFactory.getDbTableName()).changes().optArg("include_initial", true).
+                Cursor<RethinkChange> changeCursor = r.db(connectionFactory.getDbName()).
+                        table(connectionFactory.getDbTableName())
+                        .changes().optArg("include_initial", true).
                         run(connection, RethinkChange.class);
                 while (changeCursor.hasNext()) {
                     RethinkChange changedData = changeCursor.next();
-                    eventPublisher.publishEvent(new RethinkAppChange(this, changedData.getOld_val(), changedData.getNew_val()));
+                    eventPublisher.publishEvent(
+                            new RethinkAppChange(this, changedData.getOld_val(), changedData.getNew_val()));
                 }
             } catch (Exception e) {
                 System.out.println("error "+e);

SNMP_Pipeline/api-gateway/target/classes/application.properties

@@ -17,7 +17,14 @@ spring.cloud.gateway.routes[2].uri=lb://USER-SERVICE
 spring.cloud.gateway.routes[2].predicates[0]=Path=/users/**
 spring.cloud.gateway.routes[2].filters[0]=AuthenticationFilter
 
-spring.cloud.gateway.routes[3].id=user-service
-spring.cloud.gateway.routes[3].uri=lb://USER-SERVICE
-spring.cloud.gateway.routes[3].predicates[0]=Path=/users/**
+spring.cloud.gateway.routes[3].id=feedback-service
+spring.cloud.gateway.routes[3].uri=lb://FEEDBACK-SERVICE
+spring.cloud.gateway.routes[3].predicates[0]=Path=/feedback/**
 spring.cloud.gateway.routes[3].filters[0]=AuthenticationFilter
+
+
+spring.cloud.gateway.routes[4].id=ml-model-service
+spring.cloud.gateway.routes[4].uri=lb://ML-MODEL-SERVICE
+spring.cloud.gateway.routes[4].predicates[0]=Path=/model/**
+spring.cloud.gateway.routes[4].filters[0]=AuthenticationFilter
+

SNMP_Pipeline/service-registry/src/main/resources/application.properties

 server.port = 8761
-#eureka.client.registerWithEureka=false
 eureka.client.register-with-eureka=false
 eureka.client.fetchRegistry=false
 spring.application.name=DISCOVERY_SERVICE
+
+

SNMP_Pipeline/service-registry/target/classes/application.properties

 server.port = 8761
-#eureka.client.registerWithEureka=false
 eureka.client.register-with-eureka=false
 eureka.client.fetchRegistry=false
 spring.application.name=DISCOVERY_SERVICE
+
+