pom.xml

@@ -81,6 +81,12 @@
 			<artifactId>commons-io</artifactId>
 			<version>2.6</version>
 		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+			<version>3.12.0</version>
+		</dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

src/main/kotlin/co/id/datacomsolusindo/ipphonebridge/BridgeFIlter.kt

@@ -2,6 +2,7 @@ package co.id.datacomsolusindo.ipphonebridge
 
 import com.fasterxml.jackson.databind.ObjectMapper
 import com.fasterxml.jackson.databind.ObjectWriter
+import org.apache.commons.lang3.StringUtils
 import org.apache.logging.log4j.LogManager
 import org.ini4j.Wini
 import org.springframework.core.Ordered
@@ -103,7 +104,7 @@ class BridgeFilter(private val template: SimpMessagingTemplate, val resourceLoad
                     val partStr = ow.writeValueAsString(rb).chunked(chunkSize)
                     val partialID = UUID.randomUUID().toString()
                     val st2 = System.nanoTime()
-                    if (!ClientHolder.get().containsKey(clientNumber.toString())) {
+                    if (!ClientHolder.get().containsKey(StringUtils.leftPad(clientNumber.toString(), 3, '0'))) {
 //                        subscribeGW /topic/request/reqID
 //                        sendGW "/app/partial/$client"
                         chain.doFilter(request, response)

src/main/kotlin/co/id/datacomsolusindo/ipphonebridge/SocketChecker.kt

@@ -1,22 +1,25 @@
 package co.id.datacomsolusindo.ipphonebridge
 
-import org.apache.logging.log4j.LogManager
 import org.springframework.messaging.handler.annotation.DestinationVariable
 import org.springframework.messaging.handler.annotation.MessageMapping
 import org.springframework.messaging.handler.annotation.SendTo
 import org.springframework.stereotype.Controller
 
 @Controller
-class SocketChecker {
+class SocketChecker() {
 
     @MessageMapping("/hi")
     @SendTo("/topic/healthCheck")
     @Throws(Exception::class)
     fun greeting(message: MutableMap<*, *>): MutableMap<*, *> {
-        return mutableMapOf(Pair("Hi", "I'am Ok"))
+        return if (!ClientHolder.get().containsKey(message["Hi"])) {
+            mutableMapOf(Pair("Hi", "I'am Ok"), Pair("dc", message["Hi"]))
+        } else {
+            mutableMapOf(Pair("Hi", "I'am Ok"))
+        }
     }
 
-    fun collectChunk(message: SocketChunkData, id: String){
+    fun collectChunk(message: SocketChunkData, id: String) {
         if (message.totalPart == 1) {
 //                println("one part only with id $id")
             Singletons.responseQue.getOrPut(id) {

src/main/resources/META-INF/MANIFEST.MF

@@ -0,0 +1,4 @@
+Manifest-Version: 1.0
+Main-Class: co.id.datacomsolusindo.ipphonebridge.IpPhoneBridgeApplicatio
+ nKt
+