From 62bef73c7ee0ed4083aa48097b15562008397b35 Mon Sep 17 00:00:00 2001 From: YuCheng Hu Date: Sun, 13 Oct 2019 09:00:28 -0400 Subject: [PATCH] For example file to different folder and rename it --- .../simple/HelloWorldMessageApp.java | 38 ------------------- 1 file changed, 38 deletions(-) delete mode 100644 spring-amqp/src/main/java/com/baeldung/springamqp/simple/HelloWorldMessageApp.java diff --git a/spring-amqp/src/main/java/com/baeldung/springamqp/simple/HelloWorldMessageApp.java b/spring-amqp/src/main/java/com/baeldung/springamqp/simple/HelloWorldMessageApp.java deleted file mode 100644 index 25dcdf29c1..0000000000 --- a/spring-amqp/src/main/java/com/baeldung/springamqp/simple/HelloWorldMessageApp.java +++ /dev/null @@ -1,38 +0,0 @@ -package com.baeldung.springamqp.simple; - -import org.springframework.amqp.core.Queue; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.amqp.rabbit.core.RabbitTemplate; -import org.springframework.boot.ApplicationRunner; -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.context.annotation.Bean; - -@SpringBootApplication -public class HelloWorldMessageApp { - - private static final boolean NON_DURABLE = false; - private static final String MY_QUEUE_NAME = "myQueue"; - - public static void main(String[] args) { - SpringApplication.run(HelloWorldMessageApp.class, args); - } - - @Bean - public ApplicationRunner runner(RabbitTemplate template) { - return args -> { - template.convertAndSend("myQueue", "Hello, world!"); - }; - } - - @Bean - public Queue myQueue() { - return new Queue(MY_QUEUE_NAME, NON_DURABLE); - } - - @RabbitListener(queues = MY_QUEUE_NAME) - public void listen(String in) { - System.out.println("Message read from myQueue : " + in); - } - -}