From 5dd4ee6f0f34d680915798985824d230e717a2df Mon Sep 17 00:00:00 2001 From: YuCheng Hu Date: Sun, 13 Oct 2019 02:12:55 -0400 Subject: [PATCH] Broadcast conf AMQP app --- .../springamqp/broadcast/BroadcastConfig.java | 2 +- .../broadcast/BroadcastMessageApp.java | 16 +++++++--------- 2 files changed, 8 insertions(+), 10 deletions(-) rename spring-amqp/src/main/java/com/{baeldung => ossez}/springamqp/broadcast/BroadcastConfig.java (98%) rename spring-amqp/src/main/java/com/{baeldung => ossez}/springamqp/broadcast/BroadcastMessageApp.java (77%) diff --git a/spring-amqp/src/main/java/com/baeldung/springamqp/broadcast/BroadcastConfig.java b/spring-amqp/src/main/java/com/ossez/springamqp/broadcast/BroadcastConfig.java similarity index 98% rename from spring-amqp/src/main/java/com/baeldung/springamqp/broadcast/BroadcastConfig.java rename to spring-amqp/src/main/java/com/ossez/springamqp/broadcast/BroadcastConfig.java index 12c5987cc4..32fb532a01 100644 --- a/spring-amqp/src/main/java/com/baeldung/springamqp/broadcast/BroadcastConfig.java +++ b/spring-amqp/src/main/java/com/ossez/springamqp/broadcast/BroadcastConfig.java @@ -1,4 +1,4 @@ -package com.baeldung.springamqp.broadcast; +package com.ossez.springamqp.broadcast; import org.springframework.amqp.core.*; import org.springframework.context.annotation.Bean; diff --git a/spring-amqp/src/main/java/com/baeldung/springamqp/broadcast/BroadcastMessageApp.java b/spring-amqp/src/main/java/com/ossez/springamqp/broadcast/BroadcastMessageApp.java similarity index 77% rename from spring-amqp/src/main/java/com/baeldung/springamqp/broadcast/BroadcastMessageApp.java rename to spring-amqp/src/main/java/com/ossez/springamqp/broadcast/BroadcastMessageApp.java index 64bf3ffb93..8cb07de3e6 100644 --- a/spring-amqp/src/main/java/com/baeldung/springamqp/broadcast/BroadcastMessageApp.java +++ b/spring-amqp/src/main/java/com/ossez/springamqp/broadcast/BroadcastMessageApp.java @@ -1,4 +1,4 @@ -package com.baeldung.springamqp.broadcast; +package com.ossez.springamqp.broadcast; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.core.RabbitTemplate; @@ -7,8 +7,6 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; -import static com.baeldung.springamqp.broadcast.BroadcastConfig.*; - /** * Simple test application to send messages to rabbitMQ. * @@ -37,23 +35,23 @@ public class BroadcastMessageApp { }; } - @RabbitListener(queues = { FANOUT_QUEUE_1_NAME }) + @RabbitListener(queues = { BroadcastConfig.FANOUT_QUEUE_1_NAME }) public void receiveMessageFromFanout1(String message) { System.out.println("Received fanout 1 message: " + message); } - @RabbitListener(queues = { FANOUT_QUEUE_2_NAME }) + @RabbitListener(queues = { BroadcastConfig.FANOUT_QUEUE_2_NAME }) public void receiveMessageFromFanout2(String message) { System.out.println("Received fanout 2 message: " + message); } - @RabbitListener(queues = { TOPIC_QUEUE_1_NAME }) + @RabbitListener(queues = { BroadcastConfig.TOPIC_QUEUE_1_NAME }) public void receiveMessageFromTopic1(String message) { - System.out.println("Received topic 1 (" + BINDING_PATTERN_IMPORTANT + ") message: " + message); + System.out.println("Received topic 1 (" + BroadcastConfig.BINDING_PATTERN_IMPORTANT + ") message: " + message); } - @RabbitListener(queues = { TOPIC_QUEUE_2_NAME }) + @RabbitListener(queues = { BroadcastConfig.TOPIC_QUEUE_2_NAME }) public void receiveMessageFromTopic2(String message) { - System.out.println("Received topic 2 (" + BINDING_PATTERN_ERROR + ") message: " + message); + System.out.println("Received topic 2 (" + BroadcastConfig.BINDING_PATTERN_ERROR + ") message: " + message); } }