Announcement Announcement Module
Collapse
No announcement yet.
Configuring JMS Topic using Spring Integration Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Configuring JMS Topic using Spring Integration

    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.

  • #2
    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.

    Comment


    • #3
      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)

      Comment


      • #4
        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.

        Comment


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

          Comment


          • #6
            You might have multiple versions of a given JAR file.

            Comment


            • #7
              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">

              Comment


              • #8
                jms topic fix

                Originally posted by Mark Fisher View Post
                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....

                Comment


                • #9
                  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.

                  Comment

                  Working...
                  X