Skip to content

Commit

Permalink
chore: clean codes
Browse files Browse the repository at this point in the history
  • Loading branch information
hantsy committed Apr 29, 2024
1 parent c711057 commit 7991825
Show file tree
Hide file tree
Showing 22 changed files with 22 additions and 22 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public void send(String message) {
}

@Incoming("messages")
@Outgoing("data-stream")
@Outgoing("messages-stream")
@Broadcast
Message receive(String message) {
log.info("received: {}", message);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ public class MessageResource {
MessageHandler handler;

@Inject
@Channel("data-stream")
@Channel("messages-stream")
// Publisher<Message> stream;
// see: https://github.com/quarkusio/quarkus/issues/35219
Flow.Publisher<Message> stream;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ public Map<String, String> getConfigOverrides() {
"quarkus.amqp.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.messages-stream.connector","smallrye-in-memory"
);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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("messages-stream");

handler.send("hello");
await().atMost(Duration.ofMillis(1000)).untilAsserted(() ->
Expand Down
2 changes: 1 addition & 1 deletion amqp/src/main/java/com/example/MessageHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public void send(String message) {
}

@Incoming("messages")
@Outgoing("data-stream")
@Outgoing("messages-stream")
@Broadcast
Message receive(String message) {
log.info("received: {}", message);
Expand Down
2 changes: 1 addition & 1 deletion amqp/src/main/java/com/example/MessageResource.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ public class MessageResource {
MessageHandler handler;

@Inject
@Channel("data-stream")
@Channel("messages-stream")
// Publisher<Message> stream;
// see: https://github.com/quarkusio/quarkus/issues/35219
Flow.Publisher<Message> stream;
Expand Down
2 changes: 1 addition & 1 deletion amqp/src/test/java/com/example/InMemoryProfile.java
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ public Map<String, String> getConfigOverrides() {
"quarkus.amqp.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.messages-stream.connector", "smallrye-in-memory"
);
}

Expand Down
2 changes: 1 addition & 1 deletion amqp/src/test/java/com/example/MessageHandlerTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -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("messages-stream");

handler.send("hello");
await().atMost(Duration.ofMillis(1000)).untilAsserted(() ->
Expand Down
2 changes: 1 addition & 1 deletion kafka/src/main/java/com/example/MessageHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public void send(String message) {
}

@Incoming("messages")
@Outgoing("data-result")
@Outgoing("messages-stream")
@Broadcast
Message receive(String message) {
log.info("received: {}", message);
Expand Down
2 changes: 1 addition & 1 deletion kafka/src/main/java/com/example/MessageResource.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ public class MessageResource {
@Inject
MessageHandler handler;
@Inject
@Channel("data-stream")
@Channel("messages-stream")
// Publisher<Message> stream;
// see: https://github.com/quarkusio/quarkus/issues/35219
Flow.Publisher<Message> stream;
Expand Down
2 changes: 1 addition & 1 deletion kafka/src/test/java/com/example/InMemoryProfile.java
Original file line number Diff line number Diff line change
Expand Up @@ -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-result.connector","smallrye-in-memory"
"mp.messaging.outgoing.messages-stream.connector","smallrye-in-memory"
);
}

Expand Down
2 changes: 1 addition & 1 deletion kafka/src/test/java/com/example/MessageHandlerTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -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-result");
InMemorySink<Message> dataStream = connector.sink("messages-stream");

handler.send("hello");
await().atMost(Duration.ofMillis(1000)).untilAsserted(() ->
Expand Down
2 changes: 1 addition & 1 deletion kafka/src/test/java/com/example/MessageResourceTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,6 @@ void testSendAndReceiveMessages() {
}

assertThat(messageReplay.size()).isEqualTo(1);
assertThat(messageReplay.get(0).body()).isEqualTo("hello");
assertThat(messageReplay.getFirst().body()).isEqualTo("hello");
}
}
2 changes: 1 addition & 1 deletion pulsar/src/main/java/com/example/MessageHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public void send(String message) {
}

@Incoming("messages")
@Outgoing("data-result")
@Outgoing("messages-stream")
@Broadcast
Message receive(String message) {
log.info("received: {}", message);
Expand Down
2 changes: 1 addition & 1 deletion pulsar/src/main/java/com/example/MessageResource.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ public class MessageResource {
MessageHandler handler;

@Inject
@Channel("data-stream")
@Channel("messages-stream")
// Publisher<Message> stream;
// see: https://github.com/quarkusio/quarkus/issues/35219
Flow.Publisher<Message> stream;
Expand Down
2 changes: 1 addition & 1 deletion pulsar/src/test/java/com/example/InMemoryProfile.java
Original file line number Diff line number Diff line change
Expand Up @@ -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-result.connector","smallrye-in-memory"
"mp.messaging.outgoing.messages-stream.connector","smallrye-in-memory"
// "pulsar.client.serviceUrl", "",
// "pulsar.admin.serviceUrl", ""
);
Expand Down
2 changes: 1 addition & 1 deletion pulsar/src/test/java/com/example/MessageHandlerTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ void setUp() {
void receive() {
InMemorySource<String> messages = connector.source("messages");
InMemorySink<String> sink = connector.sink("send");
InMemorySink<Message> dataStream = connector.sink("data-result");
InMemorySink<Message> dataStream = connector.sink("messages-stream");

handler.send("hello");
await().atMost(Duration.ofMillis(1000)).untilAsserted(() ->
Expand Down
2 changes: 1 addition & 1 deletion pulsar/src/test/java/com/example/MessageResourceTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,6 @@ void testSendAndReceiveMessages() {
}

assertThat(messageReplay.size()).isEqualTo(1);
assertThat(messageReplay.get(0).body()).isEqualTo("hello");
assertThat(messageReplay.getFirst().body()).isEqualTo("hello");
}
}
2 changes: 1 addition & 1 deletion rabbitmq/src/main/java/com/example/MessageHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public void send(String message) {
}

@Incoming("messages")
@Outgoing("data-stream")
@Outgoing("messages-stream")
@Broadcast
Message receive(String message) {
log.info("received: {}", message);
Expand Down
2 changes: 1 addition & 1 deletion rabbitmq/src/main/java/com/example/MessageResource.java
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ public class MessageResource {
MessageHandler handler;

@Inject
@Channel("data-stream")
@Channel("messages-stream")
Flow.Publisher<Message> stream;

@POST
Expand Down
2 changes: 1 addition & 1 deletion rabbitmq/src/test/java/com/example/InMemoryProfile.java
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ public Map<String, String> getConfigOverrides() {
"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"
"mp.messaging.outgoing.messages-stream.connector", "smallrye-in-memory"
);
}

Expand Down
2 changes: 1 addition & 1 deletion rabbitmq/src/test/java/com/example/MessageHandlerTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -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("messages-stream");

handler.send("hello");
await().atMost(Duration.ofMillis(1000)).untilAsserted(() ->
Expand Down

0 comments on commit 7991825

Please sign in to comment.