Untitled

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>