From 2a8b557a3f4f2e2fac737eee3549b4d068d0b482 Mon Sep 17 00:00:00 2001 From: YuCheng Hu Date: Sun, 13 Oct 2019 01:47:16 -0400 Subject: [PATCH] Format source code --- .../simple/AMQPHelloWorldMessageApp.java | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) diff --git a/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java b/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java index 745d6b3c97..63c46fac1a 100644 --- a/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java +++ b/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java @@ -27,16 +27,10 @@ public class AMQPHelloWorldMessageApp { public static void main(String[] args) { -// ApplicationContext context = new AnnotationConfigApplicationContext(HelloWorldConfiguration.class); -// AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class); -// -// amqpTemplate.convertAndSend("Hello World"); -// System.out.println("Sent: Hello World"); - SpringApplication.run(AMQPHelloWorldMessageApp.class, args); } - @Bean + @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory connectionFactory = new CachingConnectionFactory(MY_QUEUE_HOSTMANME); connectionFactory.setUsername(MY_QUEUE_USERNAME); @@ -69,22 +63,20 @@ public class AMQPHelloWorldMessageApp { // return new Queue(MY_QUEUE_NAME, NON_DURABLE); - } @Bean public ApplicationRunner runner(RabbitTemplate template) { return args -> { - for (int i =0; i<1000; i++) { - template.convertAndSend("Hello, world - OSSEZ.COM!"+ i); + for (int i = 0; i < 1000; i++) { + template.convertAndSend("Hello, world - OSSEZ.COM!" + i); } }; } - @RabbitListener(queues = MY_QUEUE_NAME) public void listen(String in) { System.out.println("Message read from myQueue : " + in);