Refactor basic example

Add broadcast example
Add direct example

Author: devdevx

README.md

@@ -10,5 +10,12 @@ http://localhost:15672/
 
 Ready to run in heroku with the CloudAMQP add-on.
 
-TODO
-- End readme
+TODO end readme
+
+- End readme
+
+basic -> Default exchange
+broadcast -> Fanout exchange
+direct -> Direct exchange
+Topic exchange
+Headers exchange

src/main/java/com/devdevx/examples/springbootrabbitmq/RabbitmqApplication.java

@@ -6,7 +6,7 @@
 @SpringBootApplication
 public class RabbitmqApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(RabbitmqApplication.class, args);
-	}
+    public static void main(String[] args) {
+        SpringApplication.run(RabbitmqApplication.class, args);
+    }
 }

src/main/java/com/devdevx/examples/springbootrabbitmq/basic/Runner.java

@@ -2,14 +2,17 @@
 
 import com.devdevx.examples.springbootrabbitmq.basic.messaging.BasicMessageSender;
 import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
 
 
 @Profile("producer")
 @Component
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "basic")
 public class Runner implements CommandLineRunner {
 
+    // TODO change to schedule
     private final BasicMessageSender messageSender;
 
     public Runner(BasicMessageSender messageSender) {

src/main/java/com/devdevx/examples/springbootrabbitmq/basic/config/BasicRmqConfig.java

@@ -7,10 +7,12 @@
 import org.springframework.amqp.core.FanoutExchange;
 import org.springframework.amqp.core.Queue;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
 @Configuration
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "basic")
 public class BasicRmqConfig {
 
     private static final Logger log = LoggerFactory.getLogger(BasicRmqConfig.class);
@@ -21,9 +23,6 @@ public class BasicRmqConfig {
     @Value("${app.rabbitmq.basic.queue}")
     private String queueName;
 
-    @Value("${app.rabbitmq.basic.routing-key}")
-    private String routingKey;
-
     @Bean
     Queue queue() {
         log.info("Creating queue: {}", queueName);
@@ -54,7 +53,7 @@ Binding binding(Queue queue, FanoutExchange exchange) {
     @Bean
     Binding binding(Queue queue, DirectExchange exchange) {
         log.info("Binding queue '{}' to the exchange '{}' with the routing key ''", queueName, exchangeName);
-        return BindingBuilder.bind(queue).to(exchange).with("*");
+        return BindingBuilder.bind(queue).to(exchange).with("");
     }
     */
 }

src/main/java/com/devdevx/examples/springbootrabbitmq/basic/config/BasicRmqProduConfig.java

@@ -4,12 +4,14 @@
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Profile;
-import org.springframework.stereotype.Component;
 
 @Profile("producer")
-@Component
+@Configuration
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "basic")
 public class BasicRmqProduConfig {
 
     @Value("${app.rabbitmq.basic.exchange}")

src/main/java/com/devdevx/examples/springbootrabbitmq/basic/messaging/BasicMessageReceiver.java

@@ -3,18 +3,24 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
 
 @Profile("consumer")
 @Component
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "basic")
 public class BasicMessageReceiver {
 
     private static final Logger log = LoggerFactory.getLogger(BasicMessageReceiver.class);
 
+    @Value("${app.rabbitmq.basic.queue}")
+    private String queueName;
+
     @RabbitListener(queues = "${app.rabbitmq.basic.queue}")
     public void receive(BasicMessage message) {
-        log.info("Basic message received {}", message);
+        log.info("Basic message received on queue '{}' : {}", queueName, message);
         try {
             log.info("Sleeping {}ms", message.getMs());
             Thread.sleep(message.getMs());

src/main/java/com/devdevx/examples/springbootrabbitmq/basic/messaging/BasicMessageSender.java

@@ -3,7 +3,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
 
@@ -12,14 +12,13 @@
 
 @Profile("producer")
 @Component
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "basic")
 public class BasicMessageSender {
 
     private static final Logger log = LoggerFactory.getLogger(BasicMessageSender.class);
 
-    @Value("${app.rabbitmq.basic.routing-key}")
-    private String routingKey;
-
     private RabbitTemplate rabbitTemplate;
+
     private int id = 0;
 
     public BasicMessageSender(RabbitTemplate rabbitTemplate) {
@@ -28,7 +27,7 @@ public BasicMessageSender(RabbitTemplate rabbitTemplate) {
 
     public void send() {
         BasicMessage message = new BasicMessage(id++, LocalDateTime.now().toString(), new Random().nextInt(20) * 1000);
-        log.info("Sending basic message {}", message);
+        log.info("Sending basic message: {}", message);
         rabbitTemplate.convertAndSend(message);
     }
 }

src/main/java/com/devdevx/examples/springbootrabbitmq/broadcast/Runner.java

@@ -0,0 +1,30 @@
+package com.devdevx.examples.springbootrabbitmq.broadcast;
+
+import com.devdevx.examples.springbootrabbitmq.broadcast.messaging.BroadcastMessageSender;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Component;
+
+
+@Profile("producer")
+@Component
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "broadcast")
+public class Runner implements CommandLineRunner {
+
+    // TODO change to schedule
+    private final BroadcastMessageSender messageSender;
+
+    public Runner(BroadcastMessageSender messageSender) {
+        this.messageSender = messageSender;
+    }
+
+    @Override
+    public void run(String... args) throws Exception {
+        while (true) {
+            messageSender.send();
+            Thread.sleep(10000);
+        }
+    }
+
+}

src/main/java/com/devdevx/examples/springbootrabbitmq/broadcast/config/BroadcastRmqConfig.java

@@ -0,0 +1,74 @@
+package com.devdevx.examples.springbootrabbitmq.broadcast.config;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.FanoutExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "broadcast")
+public class BroadcastRmqConfig {
+
+    private static final Logger log = LoggerFactory.getLogger(BroadcastRmqConfig.class);
+
+    @Value("${app.rabbitmq.broadcast.exchange}")
+    private String exchangeName;
+
+    @Value("${app.rabbitmq.broadcast.queue-one}")
+    private String queueNameOne;
+
+    @Value("${app.rabbitmq.broadcast.queue-two}")
+    private String queueNameTwo;
+
+    @Value("${app.rabbitmq.broadcast.queue-three}")
+    private String queueNameThree;
+
+    @Bean
+    Queue queueOne() {
+        log.info("Creating queue: {}", queueNameOne);
+        return new Queue(queueNameOne, false);
+    }
+
+    @Bean
+    Queue queueTwo() {
+        log.info("Creating queue: {}", queueNameTwo);
+        return new Queue(queueNameTwo, false);
+    }
+
+    @Bean
+    Queue queueThree() {
+        log.info("Creating queue: {}", queueNameThree);
+        return new Queue(queueNameThree, false);
+    }
+
+    @Bean
+    FanoutExchange exchange() {
+        log.info("Creating exchange: {}", exchangeName);
+        return new FanoutExchange(exchangeName);
+    }
+
+    @Bean
+    Binding bindingOne(@Qualifier("queueOne") Queue queue, FanoutExchange exchange) {
+        log.info("Binding queue '{}' to the exchange '{}'", queue.getName(), exchange.getName());
+        return BindingBuilder.bind(queue).to(exchange);
+    }
+
+    @Bean
+    Binding bindingTwo(@Qualifier("queueTwo") Queue queue, FanoutExchange exchange) {
+        log.info("Binding queue '{}' to the exchange '{}'", queue.getName(), exchange.getName());
+        return BindingBuilder.bind(queue).to(exchange);
+    }
+
+    @Bean
+    Binding bindingThree(@Qualifier("queueThree") Queue queue, FanoutExchange exchange) {
+        log.info("Binding queue '{}' to the exchange '{}'", queue.getName(), exchange.getName());
+        return BindingBuilder.bind(queue).to(exchange);
+    }
+}

src/main/java/com/devdevx/examples/springbootrabbitmq/broadcast/config/BroadcastRmqProduConfig.java

@@ -0,0 +1,28 @@
+package com.devdevx.examples.springbootrabbitmq.broadcast.config;
+
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+
+@Profile("producer")
+@Configuration
+@ConditionalOnProperty(name = "app.rabbitmq.example", havingValue = "broadcast")
+public class BroadcastRmqProduConfig {
+
+    @Value("${app.rabbitmq.broadcast.exchange}")
+    private String exchangeName;
+
+    @Bean
+    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) {
+        final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
+        rabbitTemplate.setMessageConverter(converter);
+        rabbitTemplate.setExchange(exchangeName);
+        return rabbitTemplate;
+    }
+
+}