Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Spring Integration with JMS configuration
- <!-- Channels -->
- <jms:channel id="inputChannel" queue-name="test.queue" connection-factory="connectionFactory"/>
- <!-- Consumers -->
- <jms:inbound-channel-adapter id="jmsIn" destination="requestQueue" channel="inputChannel" extract-payload="true" connection-factory="connectionFactory">
- <integration:poller time-unit="SECONDS" fixed-rate="5"/>
- </jms:inbound-channel-adapter>
- <integration:service-activator id="testActivator" input-channel="inputChannel" ref="testServiceActivator" auto-startup="true" method="handle">
- </integration:service-activator>
- <!-- Bean definitions -->
- <bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
- <property name="targetConnectionFactory">
- <bean class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL" value="tcp://127.0.0.1:61616"/>
- </bean>
- </property>
- <property name="sessionCacheSize" value="10"/>
- <property name="cacheProducers" value="false"/>
- </bean>
- <bean id="requestQueue" class="org.apache.activemq.command.ActiveMQQueue">
- <constructor-arg name="name" value="test.topic"/>
- </bean>
- <bean id="testServiceActivator" class="com.paddypower.financials.integration.PriceDistributionServiceActivator"/>
- <bean id="requestQueue" class="org.apache.activemq.command.ActiveMQTopic">
- <constructor-arg name="name" value="test.topic"/>
- </bean>
Advertisement
Add Comment
Please, Sign In to add comment