Spring AMQP 2.0.0 Milestone 4 发布

王练
 王练
发布于 2017年05月09日
收藏 12

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();
}
本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处,尊重他人劳动共创开源社区。
转载请注明:文章转载自 OSCHINA 社区 [http://www.oschina.net]
本文标题:Spring AMQP 2.0.0 Milestone 4 发布
加载中

最新评论(1

我和上帝打个赌
希望能帮到大家:http://www.codeyyy.com/linux/149-150-154.html
返回顶部
顶部