chore: clean codes

hantsy · Apr 23, 2024 · 7348c73 · 7348c73
1 parent d6bb655
commit 7348c73
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 7 deletions.
diff --git a/pulsar/src/test/java/com/example/InMemoryProfile.java b/pulsar/src/test/java/com/example/InMemoryProfile.java
@@ -11,6 +11,7 @@ public InMemoryProfile() {
     @Override
     public Map<String, String> getConfigOverrides() {
         return Map.of(
+                "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"

diff --git a/pulsar/src/test/java/com/example/MessageHandlerTest.java b/pulsar/src/test/java/com/example/MessageHandlerTest.java
@@ -46,9 +46,9 @@ void receive() {
 
 
         handler.send("hello");
-        assertThat(sink.received().get(0).getPayload()).isEqualTo("hello");
+        assertThat(sink.received().getFirst().getPayload()).isEqualTo("hello");
 
         messages.send("hello-123");
-        assertThat(dataStream.received().get(0).getPayload().body()).isEqualTo("hello-123");
+        assertThat(dataStream.received().getFirst().getPayload().body()).isEqualTo("hello-123");
     }
 }
diff --git a/rabbitmq/src/test/java/com/example/InMemoryProfile.java b/rabbitmq/src/test/java/com/example/InMemoryProfile.java
@@ -11,9 +11,10 @@ public InMemoryProfile() {
     @Override
     public Map<String, String> getConfigOverrides() {
         return Map.of(
-                "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"
+                "quarkus.rabbitmq.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"
         );
     }
 

diff --git a/rabbitmq/src/test/java/com/example/MessageHandlerTest.java b/rabbitmq/src/test/java/com/example/MessageHandlerTest.java
@@ -35,9 +35,9 @@ void receive() {
 
 
         handler.send("hello");
-        assertThat(sink.received().get(0).getPayload()).isEqualTo("hello");
+        assertThat(sink.received().getFirst().getPayload()).isEqualTo("hello");
 
         messages.send("hello-123");
-        assertThat(dataStream.received().get(0).getPayload().body()).isEqualTo("hello-123");
+        assertThat(dataStream.received().getFirst().getPayload().body()).isEqualTo("hello-123");
     }
 }