codingtim

codingtim / outboundAdapter

Created June 4, 2015 08:18

SI outbound adapter fix

	IntegrationFlows
	.from(subscribableChannel())
	.handle(Jms.outboundAdapter(jmsTemplate).destination(QUEUE2))
	.get();

codingtim / outboundAdapter

Created June 4, 2015 08:17

SI outbound adapter

	IntegrationFlows
	.from(subscribableChannel())
	.handle(Jms.outboundAdapter(jmsFactory).destination(QUEUE2))
	.get();

codingtim / subscribableChannel

Created June 4, 2015 08:16

SI subscribable channel

	IntegrationFlows
	.from(inboundChannel())
	.transform(...)
	.filter(...)
	.channel(subscribableChannel())
	.get();

codingtim / channelAdapter

Created June 4, 2015 08:15

SI channel adapter

	Jms.messageDriverChannelAdapter(jmsFactory)
	.configureListenerContainer(defaultMessageListenerContainerJmsListenerContainerSpec ->
	defaultMessageListenerContainerJmsListenerContainerSpec.sessionTransacted(true))
	.destination(QUEUE1)
	.get();

codingtim / inboundAdapter

Last active August 29, 2015 14:22

SI inbound adapter

	IntegrationFlows
	.from(jmsInboundChannelAdapter())
	.channel(inboundChannel())
	.get();