chore: clean codes

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

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/kafka/src/main/java/com/example/MessageResource.java b/kafka/src/main/java/com/example/MessageResource.java
@@ -15,7 +15,7 @@ public class MessageResource {
     @Inject
     MessageHandler handler;
     @Inject
-    @Channel("data-stream")
+    @Channel("data-result")
     // Publisher<Message> stream;
     // see: https://github.com/quarkusio/quarkus/issues/35219
     Flow.Publisher<Message> stream;

diff --git a/kafka/src/test/java/com/example/MessageResourceTest.java b/kafka/src/test/java/com/example/MessageResourceTest.java
@@ -75,6 +75,6 @@ void testSendAndReceiveMessages() {
         }
 
         assertThat(messageReplay.size()).isEqualTo(1);
-        assertThat(messageReplay.get(0).body()).isEqualTo("hello");
+        assertThat(messageReplay.getFirst().body()).isEqualTo("hello");
     }
 }
diff --git a/pulsar/src/main/java/com/example/MessageResource.java b/pulsar/src/main/java/com/example/MessageResource.java
@@ -19,7 +19,7 @@ public class MessageResource {
     MessageHandler handler;
 
     @Inject
-    @Channel("data-stream")
+    @Channel("data-result")
     // Publisher<Message> stream;
     // see: https://github.com/quarkusio/quarkus/issues/35219
     Flow.Publisher<Message> stream;

diff --git a/pulsar/src/test/java/com/example/MessageResourceTest.java b/pulsar/src/test/java/com/example/MessageResourceTest.java
@@ -75,6 +75,6 @@ void testSendAndReceiveMessages() {
         }
 
         assertThat(messageReplay.size()).isEqualTo(1);
-        assertThat(messageReplay.get(0).body()).isEqualTo("hello");
+        assertThat(messageReplay.getFirst().body()).isEqualTo("hello");
     }
 }