Enterprise Integration Zone is brought to you in partnership with:

Idan is a software engineer with experience in Server side technologies. Idan is responsible for various infrastructure models in the software industry (Telecommunications, Finance). Idan is a DZone MVB and is not an employee of DZone and has posted 5 posts at DZone. You can read more from them at their website. View Full User Profile

Spring Integrating with Remote Topic

09.26.2013
| 1262 views |
  • submit to reddit

I am going to demonstrate how to receive messages from a remote topic in Spring Integration.

First, we place the remote Topic a JBoss application server.

1. Add topic implementation jars into spring lib class-path

2. We going to create a jmsTemplate.  This makes the Java code pretty minimal and simple:

public class TgwMDB implements MessageListener
{
 
    @Override
    public void onMessage(Message msg)
    {
    }
}

3. Most of the configuration is in the applicationContextXml:

3.1 Declare jmsTemplate:

jnp://server.ip:1099
org.jnp.interfaces.NamingContextFactory
org.jboss.naming:org.jnp.interfaces

3.2 Declare jndiTopicConnFactory.

    <!-- JNDI name of connection factory as defined by provider -->  

3.3 Declare ConnectionFactory:

    <!-- Number of sessions that will be cached -->  

3.4. Declare DestinationResolver:

3.5 Declare DefaultMessageListenerContainer which will act as a cached message listener:

    // this property pubSubDomain turns the listener from Queue to Topic.  

You ready now to receive messages.



Published at DZone with permission of Idan Fridman, author and DZone MVB. (source)

(Note: Opinions expressed in this article and its replies are the opinions of their respective authors and not those of DZone, Inc.)