Announcement Announcement Module
Collapse
No announcement yet.
Simple POJO example Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Simple POJO example

    I want to be able to create a simple POJO that can receive messages from a channel that is mapped to a topic on JMS.

    Here is my code snippet




    Code:
    	<integration:message-bus/>
    
    	<bean id="consumer" class="examples.SpringIntegrationConsumer">
    		
    	</bean>
    
    	<!-- factory used to connect to JMS broker -->
    	<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    		<property name="brokerURL" value="tcp://localhost:61616"/>
    	</bean>
    
    	<integration:channel id="someChannel" />
    	
    	<integration:service-activator ref="consumer" input-channel="someChannel" method="someMethod"  />
    	
    	<integration:jms-gateway id="jmsGateway"
    		connection-factory="connectionFactory"
    		destination-name="someTopic"
    		request-channel="someChannel"
    		expect-reply="false"
    		/>
    </beans>
    Everything runs except my POJO doesn't receive the messages. I know I am missing something.
Working...
X