iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Format source code

Browse Source
This commit is contained in:
YuCheng Hu 2019-10-13 01:47:16 -04:00
parent 20b387c5dd
commit 2a8b557a3f
1 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java
View File

@ -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);