Spring/spring-amqp-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

renamed RabbitConfiguration to HelloWorldConfiguration in the sync helloworld sample

Browse Source
This commit is contained in:
Mark Fisher
2010-07-15 22:28:55 -04:00
committed by Dave Syer
parent 3820fd225b
commit 57eb5cd576
4 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
helloworld/src/main/java/org/springframework/amqp/helloworld/Consumer.java
View File

@@ -1,14 +1,13 @@
package org.springframework.amqp.helloworld;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
public class Consumer {
public static void main(String[] args) {
ApplicationContext context = new AnnotationConfigApplicationContext(RabbitConfiguration.class);
ApplicationContext context = new AnnotationConfigApplicationContext(HelloWorldConfiguration.class);
AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class);
System.out.println("Received: " + amqpTemplate.receiveAndConvert());
}

2
helloworld/src/main/java/org/springframework/amqp/helloworld/RabbitConfiguration.java → helloworld/src/main/java/org/springframework/amqp/helloworld/HelloWorldConfiguration.java
View File

@@ -9,7 +9,7 @@ import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitConfiguration extends AbstractRabbitConfiguration {
public class HelloWorldConfiguration extends AbstractRabbitConfiguration {
protected final String helloWorldQueueName = "hello.world.queue";

3
helloworld/src/main/java/org/springframework/amqp/helloworld/Producer.java
View File

@@ -1,14 +1,13 @@
package org.springframework.amqp.helloworld;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
public class Producer {
public static void main(String[] args) {
ApplicationContext context = new AnnotationConfigApplicationContext(RabbitConfiguration.class);
ApplicationContext context = new AnnotationConfigApplicationContext(HelloWorldConfiguration.class);
AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class);
amqpTemplate.convertAndSend("Hello World");
System.out.println("Sent: Hello World");

4
helloworld/src/main/java/org/springframework/amqp/helloworld/async/ConsumerConfiguration.java
View File

@@ -1,13 +1,13 @@
package org.springframework.amqp.helloworld.async;
import org.springframework.amqp.helloworld.RabbitConfiguration;
import org.springframework.amqp.helloworld.HelloWorldConfiguration;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ConsumerConfiguration extends RabbitConfiguration {
public class ConsumerConfiguration extends HelloWorldConfiguration {
@Bean
public SimpleMessageListenerContainer listenerContainer() {