5 Replies Latest reply on May 5, 2011 8:49 AM by Clebert Suconic

    JmsBridge between AS6 and JBoss ESB 4.9

    Laurent Van Basselaere Newbie

      Hello,

       

      we have the following setup:

      1 JBoss ESB 4.9 server running on standard ports and

      1 JBoss AS 6 server running on ports-01 set running on the same physical server.

       

      The application running in the AS6 must send JMS messages to the ESB JMS queue.

      We thought the most elegant solution was to use a JmsBridge in order to achieve this result. The bridge is configured as follows (btw. the hornetQ documentation contains errors in the package names in the example JMS Bridge onfiguration):

       

      <?xml version="1.0" encoding="UTF-8"?>

       

      <deployment xmlns="urn:jboss:bean-deployer:2.0">

       

             <bean name="JMSBridge" class="org.hornetq.jms.bridge.impl.JMSBridgeImpl">

                 <!-- HornetQ must be started before the bridge -->

                 <depends>HornetQServer</depends>

                 <depends>MBeanServer</depends>

                 <constructor>

                     <!-- Source ConnectionFactory Factory -->

                     <parameter>

                         <inject bean="SourceCFF"/>

                     </parameter>

                     <!-- Target ConnectionFactory Factory -->

                     <parameter>

                         <inject bean="TargetCFF"/>

                     </parameter>

                     <!-- Source DestinationFactory -->

                     <parameter>

                         <inject bean="SourceDestinationFactory"/>

                     </parameter>

                     <!-- Target DestinationFactory -->

                     <parameter>

                         <inject bean="TargetDestinationFactory"/>

                     </parameter>

                     <!-- Source User Name (no username here) -->

                     <parameter><null /></parameter>

                     <!-- Source Password (no password here)-->

                     <parameter><null /></parameter>

                     <!-- Target User Name (no username here)-->

                     <parameter><null /></parameter>

                     <!-- Target Password (no password here)-->

                     <parameter><null /></parameter>

                     <!-- Selector -->

                     <parameter><null /></parameter>

                     <!-- Failure Retry Interval (in ms) -->

                     <parameter>5000</parameter>

                     <!-- Max Retries -->

                     <parameter>10</parameter>

                     <!-- Quality Of Service -->

                     <parameter>ONCE_AND_ONLY_ONCE</parameter>

                     <!-- Max Batch Size -->

                     <parameter>1</parameter>

                     <!-- Max Batch Time (-1 means infinite) -->

                     <parameter>-1</parameter>

                     <!-- Subscription name (no subscription name here)-->

                     <parameter><null /></parameter>

                     <!-- Client ID  (no client ID here)-->

                     <parameter><null /></parameter>

                     <!-- Add MessageID In Header -->

                     <parameter>true</parameter>

                     <!-- register the JMS Bridge in the AS MBeanServer -->

                     <parameter>

                         <inject bean="MBeanServer"/>

                     </parameter>

                     <parameter>org.hornetq:service=JMSBridge</parameter>

                   </constructor>

                 <property name="transactionManager">

                     <inject bean="RealTransactionManager"/>

                 </property>

             </bean>

       

       

             <!-- SourceCFF describes the ConnectionFactory used to connect to the

                  source destination -->

             <bean name="SourceCFF"

                  class="org.hornetq.jms.bridge.impl.JNDIConnectionFactoryFactory">

                 <constructor>

                     <parameter>

                         <inject bean="source-JNDI" />

                     </parameter>

                     <parameter>/ConnectionFactory</parameter>

                 </constructor> 

             </bean>

       

             <!-- TargetCFF describes the ConnectionFactory used to connect to the

              target destination -->

             <bean name="TargetCFF"

                  class="org.hornetq.jms.bridge.impl.JNDIConnectionFactoryFactory">

                 <constructor>

                     <parameter>

                         <inject bean="target-JNDI" />

                     </parameter>

                     <parameter>/ConnectionFactory</parameter>

                 </constructor> 

             </bean>

       

             <!-- SourceDestinationFactory describes the Destination used as the source -->

             <bean name="SourceDestinationFactory"

                  class="org.hornetq.jms.bridge.impl.JNDIDestinationFactory">

                 <constructor>

                     <parameter>

                         <inject bean="source-JNDI" />

                     </parameter>

                     <parameter>/queue/akct_jms_out</parameter>

                 </constructor> 

             </bean>

       

             <!-- TargetDestinationFactory describes the Destination used as the target -->

             <bean name="TargetDestinationFactory"

                  class="org.hornetq.jms.bridge.impl.JNDIDestinationFactory">

                 <constructor>

                     <parameter>

                         <inject bean="target-JNDI" />

                     </parameter>

                     <parameter>/queue/akct_jms_in</parameter>

                 </constructor> 

             </bean>

       

            <!-- Hashtable containing the JNDI properties required to connect to the source resource -->      

            <bean name="source-JNDI" class="java.util.Hashtable">

               <constructor class="java.util.Map">

                  <map class="java.util.Hashtable" keyClass="java.lang.String" valueClass="java.lang.String">

                     <entry>

                        <key>java.naming.factory.initial</key>

                        <value>org.jnp.interfaces.NamingContextFactory</value>

                     </entry>

                     <entry>

                        <key>java.naming.provider.url</key>

                        <value>jnp://localhost:1199</value>

                     </entry>

                     <entry>

                        <key>java.naming.factory.url.pkgs</key>

                        <value>org.jnp.interfaces"</value>

                     </entry>

                     <entry>

                        <key>jnp.timeout</key>

                        <value>5000</value>

                     </entry>

                     <entry>

                        <key>jnp.sotimeout</key>

                        <value>5000</value>

                     </entry>

                  </map>

               </constructor>

            </bean>

       

            <!-- Hashtable containing the JNDI properties required to connect to the target resource -->      

            <bean name="target-JNDI" class="java.util.Hashtable">

               <constructor class="java.util.Map">

                  <map class="java.util.Hashtable" keyClass="java.lang.String" valueClass="java.lang.String">

                     <entry>

                        <key>java.naming.factory.initial</key>

                        <value>org.jnp.interfaces.NamingContextFactory</value>

                     </entry>

                     <entry>

                        <key>java.naming.provider.url</key>

                        <value>jnp://localhost:1099</value>

                     </entry>

                     <entry>

                        <key>java.naming.factory.url.pkgs</key>

                        <value>org.jnp.interfaces"</value>

                     </entry>

                     <entry>

                        <key>jnp.timeout</key>

                        <value>5000</value>

                     </entry>

                     <entry>

                        <key>jnp.sotimeout</key>

                        <value>5000</value>

                     </entry>

                  </map>

               </constructor>

            </bean>

      </deployment>

       

      This setup doesn't work. The JmsBridge fails with the following message:

       

      17:53:44,501 ATTENTION [org.hornetq.jms.bridge.impl.JMSBridgeImpl] Unable to set up connections, bridge will not be started

       

      Debugging the JmsBridgeImpl class, I found out that the exception causing the failure is:

       

      javax.naming.CommunicationException [Root exception is java.lang.ClassNotFoundException: org.jboss.jms.destination.JBossQueue (no security manager: RMI class loader disabled)]

       

      Obviously, this class is part of JBoss messaging so it's not available on the AS6 server. Have you got any suggestion?

      Or if you think of any other option for the setup, please suggest, I'm a newbie in this area.