Spring AMQP 2.0.0 Milestone 4 发布

Linuxeden 开源社区 --

Spring AMQP 2.0.0.M4 发布了，自 M3 以来的更新包括：

• 新的 DirectMessageListnerContainer 现在支持配置在 ack 之间进行消息数量处理
• 现在可以在 @RabbitListener 注释上指定容器并发

Spring AMQP 2.0.0 候选版预计会在 6 月初发布。

关于 2.0 版本的更新信息, 还可以浏览 2.0.0.M1 、 2.0.0.M2, 以及 2.0.0.M3。

Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案，提供模板化的发送和接收消息的抽象层，提供基于消息驱动的 POJO。

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();
}

转自 http://ift.tt/2qU3cz0

The post Spring AMQP 2.0.0 Milestone 4 发布 appeared first on Linuxeden开源社区.

http://ift.tt/2pezDfj