chore: clean codes

hantsy · Apr 29, 2024 · c711057 · c711057
1 parent 9411a96
commit c711057
Show file tree

Hide file tree

Showing 6 changed files with 11 additions and 10 deletions.
diff --git a/kafka/src/main/java/com/example/MessageHandler.java b/kafka/src/main/java/com/example/MessageHandler.java
@@ -23,7 +23,7 @@ public void send(String message) {
     }
 
     @Incoming("messages")
-    @Outgoing("data-stream")
+    @Outgoing("data-result")
     @Broadcast
     Message receive(String message) {
         log.info("received: {}", message);

diff --git a/kafka/src/test/java/com/example/InMemoryProfile.java b/kafka/src/test/java/com/example/InMemoryProfile.java
@@ -14,7 +14,7 @@ public Map<String, String> getConfigOverrides() {
                 "quarkus.kafka.devservices.enabled", "false",
                 "mp.messaging.outgoing.send.connector","smallrye-in-memory",
                 "mp.messaging.incoming.messages.connector","smallrye-in-memory",
-                "mp.messaging.outgoing.data-stream.connector","smallrye-in-memory"
+                "mp.messaging.outgoing.data-result.connector","smallrye-in-memory"
         );
     }
 

diff --git a/kafka/src/test/java/com/example/MessageHandlerTest.java b/kafka/src/test/java/com/example/MessageHandlerTest.java
@@ -34,7 +34,7 @@ void setUp() {
     void receive() {
         InMemorySource<String> messages = connector.source("messages");
         InMemorySink<String> sink = connector.sink("send");
-        InMemorySink<Message> dataStream = connector.sink("data-stream");
+        InMemorySink<Message> dataStream = connector.sink("data-result");
 
         handler.send("hello");
         await().atMost(Duration.ofMillis(1000)).untilAsserted(() ->

diff --git a/pulsar/src/main/java/com/example/MessageHandler.java b/pulsar/src/main/java/com/example/MessageHandler.java
@@ -23,7 +23,7 @@ public void send(String message) {
     }
 
     @Incoming("messages")
-    @Outgoing("data-stream")
+    @Outgoing("data-result")
     @Broadcast
     Message receive(String message) {
         log.info("received: {}", message);

diff --git a/pulsar/src/test/java/com/example/InMemoryProfile.java b/pulsar/src/test/java/com/example/InMemoryProfile.java
@@ -14,7 +14,7 @@ public Map<String, String> getConfigOverrides() {
                 "quarkus.pulsar.devservices.enabled", "false",
                 "mp.messaging.outgoing.send.connector","smallrye-in-memory",
                 "mp.messaging.incoming.messages.connector","smallrye-in-memory",
-                "mp.messaging.outgoing.data-stream.connector","smallrye-in-memory"
+                "mp.messaging.outgoing.data-result.connector","smallrye-in-memory"
 //                "pulsar.client.serviceUrl", "",
 //                "pulsar.admin.serviceUrl", ""
         );

diff --git a/pulsar/src/test/java/com/example/MessageHandlerTest.java b/pulsar/src/test/java/com/example/MessageHandlerTest.java
@@ -35,17 +35,18 @@ class MessageHandlerTest {
     @BeforeEach
     void setUp() {
         final Iterable<String> propertyNames = config.getPropertyNames();
-        for (final String propertyName : propertyNames) {
-            final String propertyValue = config.getValue(propertyName, String.class);
-            log.debug(propertyName + " = " + propertyValue);
-        }
+        log.debug("properties: {}", propertyNames);
+//        for (final String propertyName : propertyNames) {
+//            final String propertyValue = config.getValue(propertyName, String.class);
+//            log.debug(propertyName + " = " + propertyValue);
+//        }
     }
 
     @Test
     void receive() {
         InMemorySource<String> messages = connector.source("messages");
         InMemorySink<String> sink = connector.sink("send");
-        InMemorySink<Message> dataStream = connector.sink("data-stream");
+        InMemorySink<Message> dataStream = connector.sink("data-result");
 
         handler.send("hello");
         await().atMost(Duration.ofMillis(1000)).untilAsserted(() ->