Some cleaning for infinity

SNMP_Pipeline/.idea/compiler.xml

@@ -15,6 +15,7 @@
         <module name="identity-service" />
         <module name="service-registry" />
         <module name="kafkaConsumerSNMP" />
+        <module name="Processing" />
       </profile>
     </annotationProcessing>
     <bytecodeTargetLevel>
@@ -22,6 +23,7 @@
       <module name="api-gateway" target="17" />
       <module name="identity-service" target="17" />
       <module name="kafkaConsumerSNMP" target="17" />
+      <module name="Processing" target="17" />
       <module name="service-discovery" target="1.5" />
       <module name="service-registry" target="17" />
       <module name="SnmpReciever" target="17" />
@@ -34,6 +36,7 @@
   <component name="JavacSettings">
     <option name="ADDITIONAL_OPTIONS_OVERRIDE">
       <module name="Api-gateway" options="" />
+      <module name="Processing" options="-parameters" />
       <module name="SnmpReciever" options="-parameters" />
       <module name="Trap Stream" options="-parameters" />
       <module name="TrapStream" options="-parameters" />

SNMP_Pipeline/.idea/modules.xml

@@ -2,6 +2,7 @@
 <project version="4">
   <component name="ProjectModuleManager">
     <modules>
+      <module fileurl="file://$PROJECT_DIR$/TrapStream/Processing.iml" filepath="$PROJECT_DIR$/TrapStream/Processing.iml" />
       <module fileurl="file://$PROJECT_DIR$/SnmpReciever/SnmpReciever.iml" filepath="$PROJECT_DIR$/SnmpReciever/SnmpReciever.iml" />
       <module fileurl="file://$PROJECT_DIR$/TrapStream/TrapStream.iml" filepath="$PROJECT_DIR$/TrapStream/TrapStream.iml" />
       <module fileurl="file://$PROJECT_DIR$/Web-Application/Web-Application.iml" filepath="$PROJECT_DIR$/Web-Application/Web-Application.iml" />

SNMP_Pipeline/Processing/.idea/workspace.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="AutoImportSettings">
+    <option name="autoReloadType" value="SELECTIVE" />
+  </component>
+  <component name="ChangeListManager">
+    <list default="true" id="9ca544f9-ecd7-4a81-a9c6-5187030e3251" name="Changes" comment="">
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__com_google_code_gson_gson_2_8_9.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__com_googlecode_json_simple_json_simple_1_1_1.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__com_rethinkdb_rethinkdb_driver_2_4_0.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__io_projectreactor_reactor_core_3_5_6.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__junit_junit_4_13_2.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__org_hamcrest_hamcrest_core_2_2.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__org_reactivestreams_reactive_streams_1_0_4.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_websocket_3_1_0.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../.idea/libraries/Maven__org_springframework_spring_websocket_6_0_9.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/configuration/SocketTextHandler.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/configuration/WebSocketConfig.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../../First_Pipeline/docker-compose-rethink.yml" beforeDir="false" afterPath="$PROJECT_DIR$/../../First_Pipeline/docker-compose-rethink.yml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../SnmpReciever/src/main/java/com/example/SnmpReciever/configuration/KafkaProducerConfig.java" beforeDir="false" afterPath="$PROJECT_DIR$/../SnmpReciever/src/main/java/com/example/SnmpReciever/configuration/KafkaProducerConfig.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../SnmpReciever/src/main/resources/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/../SnmpReciever/src/main/resources/application.properties" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../SnmpReciever/target/classes/com/example/SnmpReciever/enitites/TrapData.class" beforeDir="false" afterPath="$PROJECT_DIR$/../SnmpReciever/target/classes/com/example/SnmpReciever/enitites/TrapData.class" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/kafkaConsumerSNMP.iml" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/kafkaConsumerSNMP.iml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/pom.xml" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/pom.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/KafkaConsumerSnmpApplication.java" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/KafkaConsumerSnmpApplication.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/configuration/elasticConfig.java" beforeDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/entities/TrapData.java" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/entities/TrapData.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/entities/VarBind.java" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/entities/VarBind.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/java/com/example/kafkaConsumerSNMP/services/ElasticDataStream.java" beforeDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/resources/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/src/main/resources/application.properties" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/application.properties" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/KafkaConsumerSnmpApplication.class" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/KafkaConsumerSnmpApplication.class" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/configuration/elasticConfig.class" beforeDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/entities/TrapData.class" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/entities/TrapData.class" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/entities/VarBind.class" beforeDir="false" afterPath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/entities/VarBind.class" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/../kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/services/ElasticDataStream.class" beforeDir="false" />
+    </list>
+    <option name="SHOW_DIALOG" value="false" />
+    <option name="HIGHLIGHT_CONFLICTS" value="true" />
+    <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
+    <option name="LAST_RESOLUTION" value="IGNORE" />
+  </component>
+  <component name="Git.Settings">
+    <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$/../.." />
+  </component>
+  <component name="MavenImportPreferences">
+    <option name="generalSettings">
+      <MavenGeneralSettings>
+        <option name="mavenHome" value="Use Maven wrapper" />
+        <option name="useMavenConfig" value="true" />
+      </MavenGeneralSettings>
+    </option>
+  </component>
+  <component name="ProjectId" id="2SEzNWuIlUo9UhBwDcpZZwCYqFf" />
+  <component name="ProjectLevelVcsManager" settingsEditedManually="true" />
+  <component name="ProjectViewState">
+    <option name="hideEmptyMiddlePackages" value="true" />
+    <option name="showLibraryContents" value="true" />
+  </component>
+  <component name="PropertiesComponent"><![CDATA[{
+  "keyToString": {
+    "RunOnceActivity.OpenProjectViewOnStart": "true",
+    "RunOnceActivity.ShowReadmeOnStart": "true"
+  }
+}]]></component>
+  <component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
+  <component name="Vcs.Log.Tabs.Properties">
+    <option name="TAB_STATES">
+      <map>
+        <entry key="MAIN">
+          <value>
+            <State />
+          </value>
+        </entry>
+      </map>
+    </option>
+  </component>
+</project>
\ No newline at end of file

SNMP_Pipeline/SnmpReciever/.idea/.gitignore

+# Default ignored files
+/shelf/
+/workspace.xml

SNMP_Pipeline/SnmpReciever/.idea/compiler.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="CompilerConfiguration">
+    <annotationProcessing>
+      <profile default="true" name="Default" enabled="true" />
+      <profile name="Maven default annotation processors profile" enabled="true">
+        <sourceOutputDir name="target/generated-sources/annotations" />
+        <sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
+        <outputRelativeToContentRoot value="true" />
+        <module name="SnmpReciever" />
+      </profile>
+    </annotationProcessing>
+  </component>
+  <component name="JavacSettings">
+    <option name="ADDITIONAL_OPTIONS_OVERRIDE">
+      <module name="SnmpReciever" options="-parameters" />
+    </option>
+  </component>
+</project>
\ No newline at end of file

SNMP_Pipeline/SnmpReciever/.idea/encodings.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Encoding">
+    <file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
+  </component>
+</project>
\ No newline at end of file

SNMP_Pipeline/SnmpReciever/.idea/jarRepositories.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="RemoteRepositoriesConfiguration">
+    <remote-repository>
+      <option name="id" value="central" />
+      <option name="name" value="Central Repository" />
+      <option name="url" value="https://repo.maven.apache.org/maven2" />
+    </remote-repository>
+    <remote-repository>
+      <option name="id" value="central" />
+      <option name="name" value="Maven Central repository" />
+      <option name="url" value="https://repo1.maven.org/maven2" />
+    </remote-repository>
+    <remote-repository>
+      <option name="id" value="jboss.community" />
+      <option name="name" value="JBoss Community repository" />
+      <option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
+    </remote-repository>
+  </component>
+</project>
\ No newline at end of file

SNMP_Pipeline/SnmpReciever/.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ExternalStorageConfigurationManager" enabled="true" />
+  <component name="MavenProjectsManager">
+    <option name="originalFiles">
+      <list>
+        <option value="$PROJECT_DIR$/pom.xml" />
+      </list>
+    </option>
+  </component>
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
+</project>
\ No newline at end of file

SNMP_Pipeline/SnmpReciever/.idea/vcs.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$/../.." vcs="Git" />
+  </component>
+</project>
\ No newline at end of file

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

@@ -2,9 +2,11 @@ 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=192.168.27.227/1625
-spring.listener.threads=20
+
+spring.listener.address=192.168.24.47/1625
+spring.listener.threads=10
 spring.listener.community=public
+
 spring.application.name=TRAP-LISTENER-SERVICE
-eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka
+eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
 

SNMP_Pipeline/SnmpReciever/target/classes/application.properties

@@ -2,9 +2,11 @@ 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=192.168.27.227/1625
-spring.listener.threads=20
+
+spring.listener.address=192.168.24.47/1625
+spring.listener.threads=1
 spring.listener.community=public
+
 spring.application.name=TRAP-LISTENER-SERVICE
-eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka
+eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
 

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

@@ -14,6 +14,7 @@ rethinkdb.port = 28015
 rethinkDBName = Traps
 rethinkDBTableName = Raw-Traps
 
-spring.application.name=TRAP-CONSUMER-SERVICE
-eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka
+spring.application.name=TRAP-SERVICE
+eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
+
 

SNMP_Pipeline/kafkaConsumerSNMP/target/classes/application.properties

@@ -14,6 +14,7 @@ rethinkdb.port = 28015
 rethinkDBName = Traps
 rethinkDBTableName = Raw-Traps
 
-spring.application.name=TRAP-CONSUMER-SERVICE
-eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka
+spring.application.name=TRAP-SERVICE
+eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
+