0 Replies Latest reply on Apr 14, 2010 11:39 AM by Brian Ploetz

    Creating a durable subscription to a remote Topic via EJB3 MDBs

    Brian Ploetz Newbie

      (NOTE: JBoss 4.2.3)

       

      Hi all,

       

      I'm trying to get the following configuration working and running into an issue:

       

      Server 1: Hosts a Durable Topic, and contains a component (a web app) which publishes mesages to this Topic.

      Servers 2-N: Contain EJB3 MDBs which are configured to have durable subscriptions to this remote Topic on Server 1.

       

       

      On Server 1, I have the following configured:

       

      deploy/jms/networkUpdateTopic-service.xml:

      <server>
      
        <mbean code="org.jboss.mq.server.jmx.Topic"
           name="jboss.mq.destination:service=Topic,name=networkUpdateDurableTopic">
          <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
          <depends optional-attribute-name="SecurityManager">jboss.mq:service=SecurityManager</depends>
          <attribute name="SecurityConf">
             <security>
               <role name="networkUpdateSubscriber" read="true" write="false" create="true"/>
               <role name="networkUpdatePublisher" read="true" write="true" create="true"/>
            </security>
          </attribute>
        </mbean>
      </server>
      

       

      deploy/jms/oracle-jdbc-state-service.xml:

      <server>
      
        <!-- ==================================================================== -->
        <!-- JBossMQ State Management                                             -->
        <!--                                                                      -->
        <!-- ==================================================================== -->
         
        <!-- A Statemanager that stores state in the database -->
        <mbean code="org.jboss.mq.sm.jdbc.JDBCStateManager"
                name="jboss.mq:service=StateManager">
          <depends optional-attribute-name="ConnectionManager">jboss.jca:service=DataSourceBinding,name=networkDS</depends>
          <attribute name="SqlProperties">
            CREATE_TABLES_ON_STARTUP = TRUE
            CREATE_USER_TABLE = CREATE TABLE JMS_USERS (USERID VARCHAR(32) NOT NULL, PASSWD VARCHAR(32) NOT NULL, \
                                                       CLIENTID VARCHAR(128) NULL, PRIMARY KEY(USERID))
            CREATE_ROLE_TABLE = CREATE TABLE JMS_ROLES (ROLEID VARCHAR(32) NOT NULL, USERID VARCHAR(32) NOT NULL, \
                                                       PRIMARY KEY(USERID, ROLEID))
            CREATE_SUBSCRIPTION_TABLE = CREATE TABLE JMS_SUBSCRIPTIONS (CLIENTID VARCHAR(128) NOT NULL, \
                                                       SUBNAME VARCHAR(128) NOT NULL, TOPIC VARCHAR(255) NOT NULL, \
                                                       SELECTOR VARCHAR(255) NULL, PRIMARY KEY(CLIENTID, SUBNAME))
            GET_SUBSCRIPTION = SELECT TOPIC, SELECTOR FROM JMS_SUBSCRIPTIONS WHERE CLIENTID=? AND SUBNAME=?
            LOCK_SUBSCRIPTION = SELECT TOPIC, SELECTOR FROM JMS_SUBSCRIPTIONS WHERE CLIENTID=? AND SUBNAME=?
            GET_SUBSCRIPTIONS_FOR_TOPIC = SELECT CLIENTID, SUBNAME, SELECTOR FROM JMS_SUBSCRIPTIONS WHERE TOPIC=?
            INSERT_SUBSCRIPTION = INSERT INTO JMS_SUBSCRIPTIONS (CLIENTID, SUBNAME, TOPIC, SELECTOR) VALUES(?,?,?,?)
            UPDATE_SUBSCRIPTION = UPDATE JMS_SUBSCRIPTIONS SET TOPIC=?, SELECTOR=? WHERE CLIENTID=? AND SUBNAME=?
            REMOVE_SUBSCRIPTION = DELETE FROM JMS_SUBSCRIPTIONS WHERE CLIENTID=? AND SUBNAME=?
            GET_USER_BY_CLIENTID = SELECT USERID, PASSWD, CLIENTID FROM JMS_USERS WHERE CLIENTID=?
            GET_USER = SELECT PASSWD, CLIENTID FROM JMS_USERS WHERE USERID=?
            POPULATE.TABLES.01 = INSERT INTO JMS_USERS (USERID, PASSWD, CLIENTID) VALUES ('network', 'network', 'network')
            POPULATE.TABLES.02 = INSERT INTO JMS_USERS (USERID, PASSWD, CLIENTID) VALUES ('whitelabel1', 'whitelabel1', 'whitelabel1')
            POPULATE.TABLES.03 = INSERT INTO JMS_USERS (USERID, PASSWD, CLIENTID) VALUES ('whitelabel2', 'whitelabel2', 'whitelabel2')
            POPULATE.TABLES.04 = INSERT INTO JMS_ROLES (ROLEID, USERID) VALUES ('networkUpdateSubscriber', 'whitelabel1')
            POPULATE.TABLES.05 = INSERT INTO JMS_ROLES (ROLEID, USERID) VALUES ('networkUpdateSubscriber', 'whitelabel2')
            POPULATE.TABLES.06 = INSERT INTO JMS_ROLES (ROLEID, USERID) VALUES ('networkUpdatePublisher', 'network')
            POPULATE.TABLES.07 = INSERT INTO JMS_SUBSCRIPTIONS (CLIENTID, SUBNAME, TOPIC) VALUES ('whitelabel1', 'networkUpdateSubscription', 'topic/networkUpdateDurableTopic')
            POPULATE.TABLES.08 = INSERT INTO JMS_SUBSCRIPTIONS (CLIENTID, SUBNAME, TOPIC) VALUES ('whitelabel2', 'networkUpdateSubscription', 'topic/networkUpdateDurableTopic')
          </attribute>
        </mbean>
      
      </server>
      

       

      deploy/jms/oracle-jdbc2-service.xml:

      <server>
      
        <!-- ==================================================================== -->
        <!-- Persistence and caching using Oracle                                 -->
        <!-- IMPORTANT: Remove hsqldb-jdbc2-service.xml                           -->
        <!-- ==================================================================== -->
      
        <!--
           | The destination manager is the core service within JBossMQ
        -->
        <mbean code="org.jboss.mq.server.jmx.DestinationManager" name="jboss.mq:service=DestinationManager">
          <depends optional-attribute-name="MessageCache">jboss.mq:service=MessageCache</depends>
          <depends optional-attribute-name="PersistenceManager">jboss.mq:service=PersistenceManager</depends>
          <depends optional-attribute-name="StateManager">jboss.mq:service=StateManager</depends>
          <depends optional-attribute-name="ThreadPool">jboss.mq:service=ThreadPool</depends>
          <depends>jboss:service=Naming</depends>
        </mbean>
      
        <!--
           | The MessageCache decides where to put JBossMQ message that
           | are sitting around waiting to be consumed by a client.
           |
           | The memory marks are in Megabytes.  Once the JVM memory usage hits
           | the high memory mark, the old messages in the cache will start getting
           | stored in the DataDirectory.  As memory usage gets closer to the
           | Max memory mark, the amount of message kept in the memory cache aproaches 0.
         -->
        <mbean code="org.jboss.mq.server.MessageCache"
           name="jboss.mq:service=MessageCache">
          <attribute name="HighMemoryMark">50</attribute>
          <attribute name="MaxMemoryMark">60</attribute>
          <attribute name="CacheStore">jboss.mq:service=PersistenceManager</attribute>
        </mbean>
      
        <!-- The PersistenceManager is used to store messages to disk. -->
        <!-- 
           | The jdbc2 PersistenceManager is the new improved JDBC implementation.
           | This implementation allows you to control how messages are stored in 
           | the database.
           | 
           | This jdbc2 PM configuration has been tested against Oracle
           | 
           | Use the OracleThinPeristenceManager if you have the 4K limit problem for blobs
           | this uses the INSERT_EMPTY_BLOB and LOCK_EMPTY_BLOB before updating the row
           | with the real blob data to workaround that limit.
         -->
        <!--mbean code="org.jboss.mq.pm.jdbc2.OracleThinPersistenceManager" -->
        <mbean code="org.jboss.mq.pm.jdbc2.PersistenceManager"
           name="jboss.mq:service=PersistenceManager">
          <depends optional-attribute-name="ConnectionManager">jboss.jca:service=DataSourceBinding,name=networkDS</depends>
          <attribute name="SqlProperties">
            INSERT_EMPTY_BLOB = INSERT INTO JMS_MESSAGES (MESSAGEID, DESTINATION, MESSAGEBLOB, TXID, TXOP) VALUES(?,?,EMPTY_BLOB(),?,?)
            LOCK_EMPTY_BLOB = SELECT MESSAGEID, MESSAGEBLOB FROM JMS_MESSAGES WHERE MESSAGEID = ? AND DESTINATION = ? FOR UPDATE
            BLOB_TYPE=BINARYSTREAM_BLOB
            INSERT_TX = INSERT INTO JMS_TRANSACTIONS (TXID) values(?)
            INSERT_MESSAGE = INSERT INTO JMS_MESSAGES (MESSAGEID, DESTINATION, MESSAGEBLOB, TXID, TXOP) VALUES(?,?,?,?,?)
            SELECT_ALL_UNCOMMITED_TXS = SELECT TXID FROM JMS_TRANSACTIONS
            SELECT_MAX_TX = SELECT MAX(TXID) FROM (SELECT MAX(TXID) AS TXID FROM JMS_TRANSACTIONS UNION SELECT MAX(TXID) AS TXID FROM JMS_MESSAGES)
            DELETE_ALL_TX = DELETE FROM JMS_TRANSACTIONS
            SELECT_MESSAGES_IN_DEST = SELECT MESSAGEID, MESSAGEBLOB FROM JMS_MESSAGES WHERE DESTINATION=?
            SELECT_MESSAGE_KEYS_IN_DEST = SELECT MESSAGEID FROM JMS_MESSAGES WHERE DESTINATION=?
            SELECT_MESSAGE = SELECT MESSAGEID, MESSAGEBLOB FROM JMS_MESSAGES WHERE MESSAGEID=? AND DESTINATION=?
            MARK_MESSAGE = UPDATE JMS_MESSAGES SET TXID=?, TXOP=? WHERE MESSAGEID=? AND DESTINATION=?
            UPDATE_MESSAGE = UPDATE JMS_MESSAGES SET MESSAGEBLOB=? WHERE MESSAGEID=? AND DESTINATION=?
            UPDATE_MARKED_MESSAGES = UPDATE JMS_MESSAGES SET TXID=?, TXOP=? WHERE TXOP=?
            UPDATE_MARKED_MESSAGES_WITH_TX = UPDATE JMS_MESSAGES SET TXID=?, TXOP=? WHERE TXOP=? AND TXID=?
            DELETE_MARKED_MESSAGES_WITH_TX = DELETE FROM JMS_MESSAGES MESS WHERE TXOP=? AND EXISTS (SELECT TXID FROM JMS_TRANSACTIONS TX WHERE TX.TXID = MESS.TXID)
            DELETE_TX = DELETE FROM JMS_TRANSACTIONS WHERE TXID = ?
            DELETE_MARKED_MESSAGES = DELETE FROM JMS_MESSAGES WHERE TXID=? AND TXOP=?
            DELETE_TEMPORARY_MESSAGES = DELETE FROM JMS_MESSAGES WHERE TXOP='T'
            DELETE_MESSAGE = DELETE FROM JMS_MESSAGES WHERE MESSAGEID=? AND DESTINATION=?
            CREATE_MESSAGE_TABLE = CREATE TABLE JMS_MESSAGES ( MESSAGEID INTEGER NOT NULL, \
               DESTINATION VARCHAR(255) NOT NULL, TXID INTEGER, TXOP CHAR(1), \
               MESSAGEBLOB BLOB, PRIMARY KEY (MESSAGEID, DESTINATION) )
            CREATE_IDX_MESSAGE_TXOP_TXID = CREATE INDEX JMS_MESSAGES_TXOP_TXID ON JMS_MESSAGES (TXOP, TXID)
            CREATE_IDX_MESSAGE_DESTINATION = CREATE INDEX JMS_MESSAGES_DESTINATION ON JMS_MESSAGES (DESTINATION)
            CREATE_TX_TABLE = CREATE TABLE JMS_TRANSACTIONS ( TXID INTEGER, PRIMARY KEY (TXID) )
            CREATE_TABLES_ON_STARTUP = TRUE
          </attribute>
          <!-- Uncomment to override the transaction timeout for recovery per queue/subscription, in seconds -->
          <!--attribute name="RecoveryTimeout">0</attribute-->
          <!-- The number of blobs to load at once during message recovery -->
          <attribute name="RecoverMessagesChunk">0</attribute>
        </mbean>
      
      </server>
      

       

       

      The JMS tables in Server 1's database appear to get populated correctly, and I see the following output when Server 1 starts up:

       

      10:52:47,275 TRACE [Invoker] Constructing
      10:52:47,275 TRACE [InterceptorLoader] Constructing
      10:52:47,291 TRACE [SecurityManager] Constructing
      10:52:47,400 TRACE [SecurityMetadata] Adding role: Role {name=guest;read=true;write=true;create=true}
      10:52:47,463 TRACE [Queue] Constructing
      10:52:47,510 TRACE [JVMServerILService] Constructing
      10:52:47,525 TRACE [Topic] Constructing
      10:52:47,541 DEBUG [networkUpdateDurableTopic] Setting securityConf: [security: null]
      10:52:47,557 TRACE [JDBCStateManager] Constructing
      10:52:47,588 TRACE [DestinationManager] Constructing
      10:52:47,588 TRACE [MessageCache] Constructing
      10:52:47,619 TRACE [PersistenceManager] Constructing
      10:52:47,635 DEBUG [MessageCache] Creating jboss.mq:service=MessageCache
      10:52:47,635 DEBUG [MessageCache] Created jboss.mq:service=MessageCache
      10:52:47,635 DEBUG [MessageCache] Starting jboss.mq:service=MessageCache
      10:52:47,635 DEBUG [MessageCache] Started jboss.mq:service=MessageCache
      10:52:47,666 TRACE [UILServerILService] Constructing
      10:52:49,369 TRACE [JMSProviderLoader] Constructing
      10:52:49,385 TRACE [ServerSessionPoolLoader] Constructing
      10:52:49,478 DEBUG [JMSProviderLoader] Creating jboss.mq:service=JMSProviderLoader,name=JMSProvider
      10:52:49,478 DEBUG [JMSProviderLoader] Created jboss.mq:service=JMSProviderLoader,name=JMSProvider
      10:52:49,478 DEBUG [ServerSessionPoolLoader] Creating jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      10:52:49,478 DEBUG [ServerSessionPoolLoader] Created jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      10:52:49,478 DEBUG [JMSProviderLoader] Starting jboss.mq:service=JMSProviderLoader,name=JMSProvider
      10:52:49,478 DEBUG [JMSProviderLoader] attempting to bind org.jboss.jms.jndi.JNDIProviderAdapter@13e6f83 to java:/DefaultJMSProvider
      10:52:49,494 DEBUG [JMSProviderLoader] Bound adapter to java:/DefaultJMSProvider
      10:52:49,494 DEBUG [JMSProviderLoader] Started jboss.mq:service=JMSProviderLoader,name=JMSProvider
      10:52:49,494 DEBUG [ServerSessionPoolLoader] Starting jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      10:52:49,494 DEBUG [ServerSessionPoolLoader] initialized with pool factory: org.jboss.jms.asf.StdServerSessionPoolFactory@5e7663
      10:52:49,494 DEBUG [ServerSessionPoolLoader] pool factory StdJMSPool bound to java:/StdJMSPool
      10:52:49,494 DEBUG [ServerSessionPoolLoader] Started jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      10:52:49,557 INFO  [ConnectionFactoryBindingService] Bound ConnectionManager 'jboss.jca:service=ConnectionFactoryBinding,name=JmsXA' to JNDI name 'java:JmsXA'
      10:52:49,666 DEBUG [JDBCStateManager] Creating jboss.mq:service=StateManager
      10:52:49,666 DEBUG [JDBCStateManager] Created jboss.mq:service=StateManager
      10:52:49,666 DEBUG [PersistenceManager] Creating jboss.mq:service=PersistenceManager
      10:52:49,666 DEBUG [PersistenceManager] Created jboss.mq:service=PersistenceManager
      10:52:49,666 DEBUG [DestinationManager] Creating jboss.mq:service=DestinationManager
      10:52:49,682 DEBUG [DestinationManager] Created jboss.mq:service=DestinationManager
      10:52:49,682 DEBUG [SecurityManager] Creating jboss.mq:service=SecurityManager
      10:52:49,682 DEBUG [SecurityManager] Created jboss.mq:service=SecurityManager
      10:52:49,682 DEBUG [InterceptorLoader] Creating jboss.mq:service=TracingInterceptor
      10:52:49,682 DEBUG [InterceptorLoader] Created jboss.mq:service=TracingInterceptor
      10:52:49,682 DEBUG [Invoker] Creating jboss.mq:service=Invoker
      10:52:49,682 DEBUG [Invoker] Created jboss.mq:service=Invoker
      10:52:49,682 DEBUG [HTTPServerILService] Creating jboss.mq:service=InvocationLayer,type=HTTP
      10:52:49,682 DEBUG [HTTPServerILService] Created jboss.mq:service=InvocationLayer,type=HTTP
      10:52:49,682 DEBUG [JVMServerILService] Creating jboss.mq:service=InvocationLayer,type=JVM
      10:52:49,682 DEBUG [JVMServerILService] Created jboss.mq:service=InvocationLayer,type=JVM
      10:52:49,682 DEBUG [UILServerILService] Creating jboss.mq:service=InvocationLayer,type=UIL2
      10:52:49,682 DEBUG [UILServerILService] Created jboss.mq:service=InvocationLayer,type=UIL2
      10:52:49,682 DEBUG [DLQ] Creating jboss.mq.destination:service=Queue,name=DLQ
      10:52:49,682 DEBUG [DLQ] Created jboss.mq.destination:service=Queue,name=DLQ
      10:52:49,682 DEBUG [networkUpdateDurableTopic] Creating jboss.mq.destination:service=Topic,name=networkUpdateDurableTopic
      10:52:49,682 DEBUG [networkUpdateDurableTopic] Created jboss.mq.destination:service=Topic,name=networkUpdateDurableTopic
      10:52:49,713 INFO  [ConnectionFactoryBindingService] Bound ConnectionManager 'jboss.jca:service=DataSourceBinding,name=networkDS' to JNDI name 'java:networkDS'
      10:52:50,369 DEBUG [JDBCStateManager] Starting jboss.mq:service=StateManager
      ............................
      10:52:50,838 DEBUG [PersistenceManager] Resolving uncommited TXS
      10:52:50,838 DEBUG [PersistenceManager] Started jboss.mq:service=PersistenceManager
      10:52:50,838 DEBUG [DestinationManager] Starting jboss.mq:service=DestinationManager
      10:52:50,853 DEBUG [DestinationManager] Started jboss.mq:service=DestinationManager
      10:52:50,853 DEBUG [SecurityManager] Starting jboss.mq:service=SecurityManager
      10:52:50,869 DEBUG [SecurityManager] Started jboss.mq:service=SecurityManager
      10:52:50,869 DEBUG [InterceptorLoader] Starting jboss.mq:service=TracingInterceptor
      10:52:50,869 DEBUG [InterceptorLoader] Started jboss.mq:service=TracingInterceptor
      10:52:50,869 DEBUG [Invoker] Starting jboss.mq:service=Invoker
      10:52:50,869 DEBUG [Invoker] Started jboss.mq:service=Invoker
      10:52:50,869 DEBUG [HTTPServerILService] Starting jboss.mq:service=InvocationLayer,type=HTTP
      10:52:50,869 TRACE [HTTPClient] created(String http://127.0.0.1:8080/jbossmq-httpil/HTTPServerILServlet)
      10:52:50,900 DEBUG [HTTPServerILService] Started jboss.mq:service=InvocationLayer,type=HTTP
      10:52:50,900 DEBUG [JVMServerILService] Starting jboss.mq:service=InvocationLayer,type=JVM
      10:52:50,900 DEBUG [JVMServerILService] Started jboss.mq:service=InvocationLayer,type=JVM
      10:52:50,900 DEBUG [UILServerILService] Starting jboss.mq:service=InvocationLayer,type=UIL2
      10:52:50,900 INFO  [UILServerILService] JBossMQ UIL service available at : /127.0.0.1:8093
      10:52:50,900 TRACE [TracingInterceptor] CALLED : getThreadGroup
      10:52:50,900 TRACE [TracingInterceptor] RETURN : getThreadGroup
      10:52:50,932 DEBUG [UILServerILService] Started jboss.mq:service=InvocationLayer,type=UIL2
      10:52:50,932 DEBUG [DLQ] Starting jboss.mq.destination:service=Queue,name=DLQ
      10:52:50,947 DEBUG [PersistenceManager] Restored 0 message(s) to: QUEUE.DLQ 0 need recovery.
      10:52:50,947 INFO  [DLQ] Bound to JNDI name: queue/DLQ
      10:52:50,947 TRACE [SecurityMetadata] Adding role: Role {name=guest;read=true;write=true;create=true}
      10:52:50,947 DEBUG [DLQ] Started jboss.mq.destination:service=Queue,name=DLQ
      10:52:50,947 DEBUG [networkUpdateDurableTopic] Starting jboss.mq.destination:service=Topic,name=networkUpdateDurableTopic
      10:52:50,963 INFO  [networkUpdateDurableTopic] Bound to JNDI name: topic/networkUpdateDurableTopic
      10:52:50,963 TRACE [SecurityMetadata] Adding role: Role {name=networkUpdateSubscriber;read=true;write=false;create=true}
      10:52:50,963 TRACE [SecurityMetadata] Adding role: Role {name=networkUpdatePublisher;read=true;write=true;create=true}
      10:52:50,963 DEBUG [networkUpdateDurableTopic] Started jboss.mq.destination:service=Topic,name=networkUpdateDurableTopic
      

       

      And the web app within Server 1 is able to publish messages to the Topic successfully.

       

       

      Servers 2 -> N are configured like so. I have set up a JNDIProviderAdapter to talk to Server 1's JNDI to get a reference to the remote Topic (NOTE: all servers are running on my laptop at the moment, which is why the host is "localhost").

       

      deploy/jms/jms-ds.xml:

      <?xml version="1.0" encoding="UTF-8"?>
      
      <connection-factories>
       
        <!-- ==================================================================== -->
        <!-- JMS Stuff                                                            -->
        <!-- ==================================================================== -->
      
        <!-- Remote provider for the Network Update Topic -->
        <mbean code="org.jboss.jms.jndi.JMSProviderLoader"
            name="jboss.mq:service=JMSProviderLoader,name=NetworkUpdateJMSProvider,server=localhost">
          <attribute name="ProviderName">NetworkUpdateJMSProvider</attribute>
          <attribute name="ProviderAdapterClass">org.jboss.jms.jndi.JNDIProviderAdapter</attribute>
          <!-- The connection factory -->
          <attribute name="FactoryRef">UIL2XAConnectionFactory</attribute>
          <!-- The queue connection factory -->
          <attribute name="QueueFactoryRef">UIL2XAConnectionFactory</attribute>
          <!-- The topic factory -->
          <attribute name="TopicFactoryRef">UIL2XAConnectionFactory</attribute>
          <!-- Connect to JNDI on the host "localhost" port 1099-->
          <attribute name="Properties">
             java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
             java.naming.factory.url.pkgs=org.jnp.interfaces
             java.naming.provider.url=localhost:1099
          </attribute>
        </mbean>
       
        <!-- The server session pool for Message Driven Beans -->
        <mbean code="org.jboss.jms.asf.ServerSessionPoolLoader"
           name="jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool">
          <depends optional-attribute-name="XidFactory">jboss:service=XidFactory</depends>
          <attribute name="PoolName">StdJMSPool</attribute>
          <attribute name="PoolFactoryClass">
            org.jboss.jms.asf.StdServerSessionPoolFactory
          </attribute>
        </mbean>
      
        <!-- JMS XA Resource adapter, use this to get transacted JMS in beans -->
        <tx-connection-factory>
          <jndi-name>JmsXA</jndi-name>
          <xa-transaction/>
          <rar-name>jms-ra.rar</rar-name>
          <connection-definition>org.jboss.resource.adapter.jms.JmsConnectionFactory</connection-definition>
          <config-property name="SessionDefaultType" type="java.lang.String">javax.jms.Topic</config-property>
          <config-property name="JmsProviderAdapterJNDI" type="java.lang.String">java:/NetworkUpdateJMSProvider</config-property>
          <security-domain-and-application>JmsXARealm</security-domain-and-application>
          <max-pool-size>20</max-pool-size>
        </tx-connection-factory>
      
      </connection-factories>
      

       

       

      Code for EJB3 MDB running on Server 2-N:

      package com.xxx.wl.ejb;
      
      import javax.jms.MessageListener;
      import javax.jms.Message;
      import javax.ejb.MessageDriven;
      import javax.ejb.ActivationConfigProperty;
      
      @MessageDriven(name="NetworkUpdateMDB", activationConfig =
      {
        @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Topic"),
        @ActivationConfigProperty(propertyName="destination", propertyValue="topic/networkUpdateDurableTopic"),
        @ActivationConfigProperty(propertyName="providerAdapterJNDI", propertyValue="java:/NetworkUpdateJMSProvider"),
        @ActivationConfigProperty(propertyName="acknowledgeMode", propertyValue="Auto-acknowledge"),
        @ActivationConfigProperty(propertyName="subscriptionDurability", propertyValue="Durable"),
        @ActivationConfigProperty(propertyName="subscriptionName", propertyValue="networkUpdateSubscription")
      }
      )
      public class NetworkUpdateMDB implements MessageListener {
      
        public void onMessage(Message msg) {
          System.out.println("\n\n\nGOT NETWORK UPDATE MESSAGE!");
        }
      }
      

       

      EJB3 MDB's jboss.xml:

      <?xml version="1.0" encoding="utf-8"?>
      <!DOCTYPE jboss PUBLIC
            "-//JBoss//DTD JBOSS 3.2//EN"
            "http://www.jboss.org/j2ee/dtd/jboss_3_2.dtd">
      <jboss>
         <enterprise-beans>
           <message-driven>
             <ejb-name>NetworkUpdateMDB</ejb-name>
             <destination-jndi-name>topic/networkUpdateDurableTopic</destination-jndi-name>
             <mdb-user>whitelabel1</mdb-user>
             <mdb-passwd>whitelabel1</mdb-passwd>
             <mdb-subscription-id>networkUpdateSubscription</mdb-subscription-id>
           </message-driven>
        </enterprise-beans>
      </jboss>
      

       

       

      Upon starting Server 2 I get the following error:

       

      11:28:39,198 DEBUG [PersistenceManager] Resolving uncommited TXS
      11:28:39,213 DEBUG [PersistenceManager] Started jboss.mq:service=PersistenceManager
      11:28:39,213 DEBUG [DestinationManager] Starting jboss.mq:service=DestinationManager
      11:28:39,213 DEBUG [DestinationManager] Started jboss.mq:service=DestinationManager
      11:28:39,213 DEBUG [SecurityManager] Starting jboss.mq:service=SecurityManager
      11:28:39,229 DEBUG [SecurityManager] Started jboss.mq:service=SecurityManager
      11:28:39,229 DEBUG [InterceptorLoader] Starting jboss.mq:service=TracingInterceptor
      11:28:39,229 DEBUG [InterceptorLoader] Started jboss.mq:service=TracingInterceptor
      11:28:39,229 DEBUG [Invoker] Starting jboss.mq:service=Invoker
      11:28:39,229 DEBUG [Invoker] Started jboss.mq:service=Invoker
      11:28:39,229 DEBUG [HTTPServerILService] Starting jboss.mq:service=InvocationLayer,type=HTTP
      11:28:39,276 DEBUG [HTTPServerILService] Started jboss.mq:service=InvocationLayer,type=HTTP
      11:28:39,276 DEBUG [JVMServerILService] Starting jboss.mq:service=InvocationLayer,type=JVM
      11:28:39,276 DEBUG [JVMServerILService] Started jboss.mq:service=InvocationLayer,type=JVM
      11:28:39,276 DEBUG [UILServerILService] Starting jboss.mq:service=InvocationLayer,type=UIL2
      11:28:39,276 INFO  [UILServerILService] JBossMQ UIL service available at : /127.0.0.1:8293
      11:28:39,307 DEBUG [UILServerILService] Started jboss.mq:service=InvocationLayer,type=UIL2
      11:28:39,307 DEBUG [DLQ] Starting jboss.mq.destination:service=Queue,name=DLQ
      11:28:39,323 DEBUG [PersistenceManager] Restored 0 message(s) to: QUEUE.DLQ 0 need recovery.
      11:28:39,323 INFO  [DLQ] Bound to JNDI name: queue/DLQ
      11:28:39,323 DEBUG [DLQ] Started jboss.mq.destination:service=Queue,name=DLQ
      11:28:39,448 DEBUG [JMSProviderLoader] Creating jboss.mq:service=JMSProviderLoader,name=NetworkUpdateJMSProvider,server=localhost
      11:28:39,448 DEBUG [JMSProviderLoader] Created jboss.mq:service=JMSProviderLoader,name=NetworkUpdateJMSProvider,server=localhost
      11:28:39,495 DEBUG [ServerSessionPoolLoader] Creating jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      11:28:39,495 DEBUG [ServerSessionPoolLoader] Created jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      11:28:39,495 DEBUG [JMSProviderLoader] Starting jboss.mq:service=JMSProviderLoader,name=NetworkUpdateJMSProvider,server=localhost
      11:28:39,495 DEBUG [JMSProviderLoader] attempting to bind org.jboss.jms.jndi.JNDIProviderAdapter@d8355 to java:/NetworkUpdateJMSProvider
      11:28:39,495 DEBUG [JMSProviderLoader] Bound adapter to java:/NetworkUpdateJMSProvider
      11:28:39,495 DEBUG [JMSProviderLoader] Started jboss.mq:service=JMSProviderLoader,name=NetworkUpdateJMSProvider,server=localhost
      11:28:39,495 DEBUG [ServerSessionPoolLoader] Starting jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      11:28:39,510 DEBUG [ServerSessionPoolLoader] initialized with pool factory: org.jboss.jms.asf.StdServerSessionPoolFactory@47c130
      11:28:39,510 DEBUG [ServerSessionPoolLoader] pool factory StdJMSPool bound to java:/StdJMSPool
      11:28:39,510 DEBUG [ServerSessionPoolLoader] Started jboss.mq:service=ServerSessionPoolMBean,name=StdJMSPool
      11:28:39,838 INFO  [ConnectionFactoryBindingService] Bound ConnectionManager 'jboss.jca:service=ConnectionFactoryBinding,name=JmsXA' to JNDI name 'java:JmsXA'
      11:28:40,385 INFO  [JmxKernelAbstraction] creating wrapper delegate for: org.jboss.ejb3.mdb.MDB
      11:28:40,401 INFO  [JmxKernelAbstraction] installing MBean: jboss.j2ee:jar=wl.network-update-mdb-1.0-SNAPSHOT.jar,name=NetworkUpdateMDB,service=EJB3 with dependencies:
      11:28:40,432 INFO  [EJBContainer] STARTED EJB: com.upromise.module.app.wl.ejb.NetworkUpdateMDB ejbName: NetworkUpdateMDB
      11:28:40,479 DEBUG [SpyDestinationObjectFactory] SpyDestinationObjectFactory->getObjectInstance()
      11:28:40,510 INFO  [EJB3Deployer] Deployed: file:/E:/jboss/jboss-4.2.3.GA/server/wl1/deploy/wl.network-update-mdb-1.0-SNAPSHOT.jar
      11:28:40,526 DEBUG [SpyDestinationObjectFactory] SpyDestinationObjectFactory->getObjectInstance()
      11:28:40,526 DEBUG [SpyConnectionFactoryObjectFactory] Extracting SpyConnectionFactory from reference
      11:28:40,526 DEBUG [SpyConnectionFactoryObjectFactory] The GenericConnectionFactory is: GenericConnectionFactory[server=org.jboss.mq.il.uil2.UILServerIL@402e11 connectionProperties={ClientILService=org.jboss.mq.il.uil2.UILClientILService, UIL_TCPNODELAY_KEY=yes, UIL_CHUNKSIZE_KEY=1000000, UIL_CONNECTADDRESS_KEY=null, UIL_CONNECTPORT_KEY=0, UIL_SOTIMEOUT_KEY=120000, UIL_RECEIVE_REPLIES_KEY=No, UIL_ADDRESS_KEY=127.0.0.1, UIL_PORT_KEY=8093, PingPeriod=60000, UIL_BUFFERSIZE_KEY=2048}]
      11:28:40,542 DEBUG [Connection] Setting the clockDaemon's thread factory
      11:28:40,557 DEBUG [SocketManager] Begin WriteTask.run Thread[UIL2.SocketManager.WriteTask#2 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      11:28:40,557 DEBUG [SocketManager] Created ObjectOutputStream
      11:28:40,557 DEBUG [SocketManager] Begin ReadTask.run Thread[UIL2.SocketManager.ReadTask#1 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      11:28:40,573 DEBUG [SocketManager] Created ObjectInputStream
      11:28:40,573 DEBUG [UILClientILService] Starting
      11:28:40,620 DEBUG [SpyDestinationObjectFactory] SpyDestinationObjectFactory->getObjectInstance()
      11:28:40,620 DEBUG [SpyConnectionFactoryObjectFactory] Extracting SpyConnectionFactory from reference
      11:28:40,620 DEBUG [SpyConnectionFactoryObjectFactory] The GenericConnectionFactory is: GenericConnectionFactory[server=org.jboss.mq.il.uil2.UILServerIL@788b76 connectionProperties={ClientILService=org.jboss.mq.il.uil2.UILClientILService, UIL_TCPNODELAY_KEY=yes, UIL_CHUNKSIZE_KEY=1000000, UIL_CONNECTADDRESS_KEY=null, UIL_CONNECTPORT_KEY=0, UIL_SOTIMEOUT_KEY=120000, UIL_RECEIVE_REPLIES_KEY=No, UIL_ADDRESS_KEY=127.0.0.1, UIL_PORT_KEY=8093, PingPeriod=60000, UIL_BUFFERSIZE_KEY=2048}]
      11:28:40,635 DEBUG [SocketManager] Begin ReadTask.run Thread[UIL2.SocketManager.ReadTask#3 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      11:28:40,667 DEBUG [SocketManager] Begin WriteTask.run Thread[UIL2.SocketManager.WriteTask#4 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      11:28:40,667 DEBUG [SocketManager] Created ObjectOutputStream
      11:28:40,667 DEBUG [SocketManager] Created ObjectInputStream
      11:28:40,667 DEBUG [UILClientILService] Starting
      11:28:41,135 WARN  [JmsActivation] Failure in jms activation org.jboss.resource.adapter.jms.inflow.JmsActivationSpec@9ac272(ra=org.jboss.resource.adapter.jms.JmsResourceAdapter@2b16b8 destination=topic/networkUpdateDurableTopic isTopic=true tx=true durable=true subscription=networkUpdateSubscription reconnect=10 provider=java:/NetworkUpdateJMSProvider user=whitelabel1 pass=<not shown> maxMessages=1 minSession=1 maxSession=15 keepAlive=60000 useDLQ=true DLQHandler=org.jboss.resource.adapter.jms.inflow.dlq.GenericDLQHandler DLQJndiName=queue/DLQ DLQUser=null DLQMaxResent=5)
      javax.jms.InvalidDestinationException: Previous topic does not exist: TOPIC.topic/networkUpdateDurableTopic
              at org.jboss.mq.sm.AbstractStateManager.setDurableSubscription(AbstractStateManager.java:143)
              at org.jboss.mq.server.JMSTopic.addSubscriber(JMSTopic.java:112)
              at org.jboss.mq.server.ClientConsumer.addSubscription(ClientConsumer.java:156)
              at org.jboss.mq.server.JMSDestinationManager.subscribe(JMSDestinationManager.java:596)
              at org.jboss.mq.server.JMSServerInterceptorSupport.subscribe(JMSServerInterceptorSupport.java:171)
              at org.jboss.mq.security.ServerSecurityInterceptor.subscribe(ServerSecurityInterceptor.java:157)
              at org.jboss.mq.server.TracingInterceptor.subscribe(TracingInterceptor.java:651)
              at org.jboss.mq.server.JMSServerInvoker.subscribe(JMSServerInvoker.java:177)
              at org.jboss.mq.il.uil2.ServerSocketManagerHandler.handleMsg(ServerSocketManagerHandler.java:188)
              at org.jboss.mq.il.uil2.SocketManager$ReadTask.handleMsg(SocketManager.java:419)
              at org.jboss.mq.il.uil2.msgs.BaseMsg.run(BaseMsg.java:398)
              at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(PooledExecutor.java:761)
              at java.lang.Thread.run(Thread.java:595)
      11:28:41,229 DEBUG [SocketManager] End ReadTask.run Thread[UIL2.SocketManager.ReadTask#3 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      11:28:41,229 DEBUG [SocketManager] End WriteTask.run Thread[UIL2.SocketManager.WriteTask#4 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      11:28:41,260 DEBUG [UILClientILService] Stopping
      11:28:41,291 DEBUG [SocketManager] End ReadTask.run Thread[UIL2.SocketManager.ReadTask#1 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      11:28:41,291 DEBUG [UILClientILService] Stopping
      11:28:41,291 DEBUG [SocketManager] End WriteTask.run Thread[UIL2.SocketManager.WriteTask#2 client=127.0.0.1:8093,5,JBossMQ Client Threads]
      

       

      Now it *appears* that it can't find the topic/networkUpdateDurableTopic object in the remote JNDI because for some reason it's appending TOPIC. to the Desitnation name, but that might be a red herring.

       

      Thanks in advance for any help you may have in getting this configured correctly.

      BP