转载

在SPRING INTEGRATION中手动开始和停止JMS LISTENER

如果要对JMS BROKER生产和消费MESSAGE，一种方式是用JmsTemplate发送和消费消息，另一种方式是SPRING INTEGRATION。

SPRING INTEGRATION是实现了EIP模式的一种框架，即使用CHANNEL和JMS-INBOUND-ADAPTER、JMS-OUTBOUND-ADAPTER，完全脱离了JmsTemplate的API。

如果需要实现这种场景：从BROKER取一条消息，处理消息，且处理途中不要再从BROKER再取消息，处理完后再取消息，再处理。

这样要求手动开始和停止JMS LISTENER，即手动开始和停止JMS-INBOUND-ADAPTER、JMS-OUTBOUND-ADAPTER。

@Bean

@InboundChannelAdapter(value = "loaderResponseChannel")

public MessageSource loaderResponseSource() throws Exception {

return Jms

.inboundAdapter(oracleConnectionFactory())

.configureJmsTemplate(

t -> t.deliveryPersistent( true )

.jmsMessageConverter(jacksonJmsMessageConverter())

).destination(jmsInbound).get();

}

当使用@InboundChannelAdapter时，会自动注册一个SourcePollingChannelAdapter ，但这个名字比较长：configrationName.loaderResponseSource.inboundChannelAdapter。

呼叫这个实例的start()和stop()方法即可。

@Bean

public IntegrationFlow controlBusFlow() {

return IntegrationFlows.from("controlBus")

.controlBus()

.get();

}

Message operation = MessageBuilder.withPayload("@configrationName.loaderResponseSource.inboundChannelAdapter.start()").build();

operationChannel.send(operation)

原文 http://www.blogjava.net/paulwong/archive/2019/10/09/434781.html

正文到此结束

所属分类： Spring

本文标签： spring CTO JMS API http UI build 2019 Oracle Connection bus tar list IO ip value bean 实例 connectionFactory java HTML message
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。