Spring AMQP 1.3.0 RC1 for Java 发布,此版本主要更新内容如下:
Listener Container
The listener container concurrency can be changed without first stopping the container and the listeners will be adjusted accordingly
The listener container can dynamically adjust the concurrent consumers, based on workload
The listener container now supports consumer priority (with RabbitMQ 3.2.x or greater)
The listener container now supports the configuration of an exclusive consumer
Rabbit Template
The RabbitTemplate now has several convenient receiveAndReply methods
The RabbitTemplate can now be configured with a RetryTemplate, enabling clients to not have to deal directly with broker connectivity issues.
Connection Factory
The Connection Factory can now cache connections rather than all users sharing the same connection (and, since M2, channels can be cached within cached connections)
There is now a SimpleRoutingConnectionFactory to determine which connection factory to use at runtime
Other Key Features
A fluent Java API is now provided to build a Message (and MessageProperties)
A fluent Java API is now provided for building a listener container retry interceptor
When using a retry interceptor, a new RepublishMessageRecoverer is available to republish failed messages (with stack trace) to another exchange
Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的 POJO。同时有 Java 和 .NET 的版本。
项目主页:http://docs.spring.io/spring-amqp/docs/1.3.0.RC1/reference/html/whats-new.html#d4e76
来自:oschina开源中国社区

