Configuring JMS Topic using Spring Integration

[aditya.chopra]

Hi,

Can someone please provide me some samples on how to configure JMS Topic using Spring integration? I want to publish a message in a topic and have multiple subscribers listen to that topic and consume the message.

[Gary Russell]

What do you need help with, there's no difference configuration-wise, just wire in a topic Destination. If you want/need a durable subscription, be sure to set the subscription-durable and durable-subscription-name attributes.

[SriGanesh78]

Can you please advise me the steps involved in making the message driven adapter for Tibco EMS topic?
I am having the following defintion but it's not working.
<bean id="emsConnectionFactory" class="com.tibco.tibjms.TibjmsTopicConnectionFacto ry"
p:serverUrl="server url"
p:userName="username"
p:userPassword="password">
</bean>
<bean id="cachedConnectionFactory" class="org.springframework.jms.connection.CachingC onnectionFactory"
p:targetConnectionFactory="emsConnectionFactory"
p:targetConnectionFactory-ref="emsConnectionFactory"
p:sessionCacheSize="1">
</bean>
<bean id="jmsListener" class="org.springframework.jms.listener.DefaultMes sageListenerContainer"
p:connectionFactory="cachedConnectionFactory"
p:connectionFactory-ref="cachedConnectionFactory"
p:destinationName="ESM Topic Namme"
pubSubDomain="true"
p:autoStartup="false">
</bean>
<jms:message-driven-channel-adapter id="jmsIn"
connection-factory="emsConnectionFactory"
destination="EMS Topic Name"
channel="exampleChannel"/>

I am getting the following error
Exception in thread "main" org.springframework.beans.factory.BeanCreationExce ption: Error creating bean with name 'org.springframework.integration.jms.ChannelPublis hingJmsMessageListener#0': Initialization of bean failed; nested exception is java.lang.reflect.MalformedParameterizedTypeExcept ion
at org.springframework.beans.factory.support.Abstract AutowireCapableBeanFactory.doCreateBean(AbstractAu towireCapableBeanFactory.java:527)
at org.springframework.beans.factory.support.Abstract AutowireCapableBeanFactory.createBean(AbstractAuto wireCapableBeanFactory.java:456)
at org.springframework.beans.factory.support.Abstract BeanFactory$1.getObject(AbstractBeanFactory.java:2 94)
at org.springframework.beans.factory.support.DefaultS ingletonBeanRegistry.getSingleton(DefaultSingleton BeanRegistry.java:225)
at org.springframework.beans.factory.support.Abstract BeanFactory.doGetBean(AbstractBeanFactory.java:291 )
at org.springframework.beans.factory.support.Abstract BeanFactory.getBean(AbstractBeanFactory.java:193)
at org.springframework.beans.factory.support.DefaultL istableBeanFactory.preInstantiateSingletons(Defaul tListableBeanFactory.java:609)
at org.springframework.context.support.AbstractApplic ationContext.finishBeanFactoryInitialization(Abstr actApplicationContext.java:918)
at org.springframework.context.support.AbstractApplic ationContext.refresh(AbstractApplicationContext.ja va:469)
at org.springframework.context.support.ClassPathXmlAp plicationContext.<init>(ClassPathXmlApplicationCon text.java:139)
at org.springframework.context.support.ClassPathXmlAp plicationContext.<init>(ClassPathXmlApplicationCon text.java:83)
at com.barcap.ocs.scheduling.main.Bootstrap.main(Boot strap.java:15)

[Mark Fisher]

Please do not post the same message multiple times in the forum. Also, please use [ CODE ] [ /CODE ] (without the spaces) around configuration and code excerpts.

Most likely your problem is due to a version conflict on the classpath. Please check that first.

[SriGanesh78]

Hi Mark, Thanks for the reply.
Can you tell me more about the conflict. How do i check the class path conflict?

[Mark Fisher]

You might have multiple versions of a given JAR file.

[SriGanesh78]

Any Specific Jar ? I am using pretty much everything latest.
[CODE]
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:integration="http://www.springframework.org/schema/integration"
xmlns:jms="http://www.springframework.org/schema/integration/jms"
xmlns="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:stream="http://www.springframework.org/schema/integration/stream"
xmlns:si-xml="http://www.springframework.org/schema/integration/xml"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-2.2.xsd
http://www.springframework.org/schema/integration/jms
http://www.springframework.org/schema/integration/jms/spring-integration-jms-2.2.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/integration/stream
http://www.springframework.org/schema/integration/stream/spring-integration-stream-2.2.xsd
http://www.springframework.org/schema/integration/xml
http://www.springframework.org/schema/integration/xml/spring-integration-xml-2.2.xsd">

[billsm]

You might have multiple versions of a given JAR file.

http://stackoverflow.com/questions/3...rizedtypeexcep


http://forum.springsource.org/showth...estion-sos!!!I have to agree with mark fisher.
Make sure you are using the right jar file....

[SriGanesh78]

Yes Mark, you are right.

The issue was because of the version conflict between two jars. Spring 2.5.1 and Spring.2.5.6. I changed to use the Spring.2.5.1 and it works now. service is getting triggered based on the message driven channel adapater.