[+] add push message client

Author: Sergei Kravchuk

README.md

@@ -1,3 +1,6 @@
+# Demo Websocket Server (proof of concept)
+
+
 Event (
   type: SUBSCRIBE, UNSUBSCRIBE, MESSAGE
   payload: Text

demo_ws_client/build.gradle.kts

@@ -21,6 +21,7 @@ dependencies {
     implementation("org.jetbrains.kotlin:kotlin-reflect")
     implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8")
     implementation(project(":demo_ws_common"))
+    implementation(project(":demo_ws_push_executor"))
 }
 
 tasks.withType<KotlinCompile> {

demo_ws_client/src/main/kotlin/net/alfss/demowsclient/DemoPushClientMain.kt

@@ -1,2 +1,21 @@
 package net.alfss.demowsclient
 
+import net.alfss.demowspushexecutor.entrypoins.http.entities.HttpPushMessageEntity
+import org.springframework.http.MediaType
+import org.springframework.web.reactive.function.client.WebClient
+import java.sql.Timestamp
+
+fun main(args: Array<String>) {
+    val client = WebClient.builder().baseUrl("http://localhost:8001").build()
+
+    val message = HttpPushMessageEntity("tours/9d1cfe43-b917-4a22-8406-2494bedf3f72", Timestamp(System.currentTimeMillis()).toString())
+
+    val result = client.post()
+        .uri("/notification/message")
+        .contentType(MediaType.APPLICATION_JSON)
+        .syncBody(message)
+        .retrieve()
+        .bodyToMono(Void::class.java).log().then()
+
+    result.block()
+}