http://projects.spring.io/spring-amqp/

    
         
     
              
      
       org.springframework.amqp
              
      
       spring-rabbit
              
      
       1.4.4.RELEASE
          
     
    

just Java...

public static void main(final String... args) throws Exception {     ConnectionFactory cf = new CachingConnectionFactory();     // set up the queue, exchange, binding on the broker     RabbitAdmin admin = new RabbitAdmin(cf);     Queue queue = new Queue("myQueue");     admin.declareQueue(queue);     TopicExchange exchange = new TopicExchange("myExchange");    admin.declareExchange(exchange);     admin.declareBinding(BindingBuilder.bind(queue).to(exchange).with("foo.*"));     // set up the listener and container     SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(cf);     Object listener = new Object() {             public void handleMessage(String foo) {             System.out.println(foo);         }      };     MessageListenerAdapter adapter = new MessageListenerAdapter(listener);     container.setMessageListener(adapter);     container.setQueueNames("myQueue");     container.start();     // send something     RabbitTemplate template = new RabbitTemplate(cf);     template.convertAndSend("myExchange", "foo.bar", "Hello, world!");     Thread.sleep(1000);     container.stop(); }

Or, the Spring way...

public static void main(final String... args) throws Exception {     AbstractApplicationContext ctx =         new ClassPathXmlApplicationContext("context.xml");     RabbitTemplate template = ctx.getBean(RabbitTemplate.class);     template.convertAndSend("Hello, world!");     Thread.sleep(1000);     ctx.destroy(); }

public class Foo {     public void listen(String foo) {         System.out.println(foo);     }  }