Return-Path: 
 <users-return-18703-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 31506 invoked from network); 10 Apr 2009 00:29:25 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3)
  by minotaur.apache.org with SMTP; 10 Apr 2009 00:29:25 -0000
Received: (qmail 16403 invoked by uid 500); 10 Apr 2009 00:29:25 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 16322 invoked by uid 500); 10 Apr 2009 00:29:24 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 16312 invoked by uid 99); 10 Apr 2009 00:29:24 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 10 Apr 2009 00:29:24 +0000
X-ASF-Spam-Status: No, hits=-0.0 required=10.0
	tests=SPF_HELO_PASS,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 10 Apr 2009 00:29:16 +0000
Received: from isper.nabble.com ([192.168.236.156])
	by kuber.nabble.com with esmtp (Exim 4.63)
	(envelope-from <lists@nabble.com>)
	id 1Ls4c3-0008Qx-5Q
	for users@activemq.apache.org; Thu, 09 Apr 2009 17:28:55 -0700
Message-ID: <22981378.post@talk.nabble.com>
Date: Thu, 9 Apr 2009 17:28:55 -0700 (PDT)
From: bwarren <brad.warren@usairways.com>
To: users@activemq.apache.org
Subject: Re: ActiveMQ / JBoss integration behaving badly?
In-Reply-To: <7b3355cb0904091711x475cdebal8eb862f92150960e@mail.gmail.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: brad.warren@usairways.com
References: <22963605.post@talk.nabble.com>
 <7b3355cb0904091711x475cdebal8eb862f92150960e@mail.gmail.com>
X-Virus-Checked: Checked by ClamAV on apache.org


The environment was at the bottom of the JBoss forum post:

JBoss 5.0.1.GA
ActiveMQ 5.2.0

We've got ActiveMQ embedded in JBoss.

Contents of activemq-jms-ds.xml:
*****************************************************************
<connection-factories>

  <tx-connection-factory>
    <jndi-name>activemq/QueueConnectionFactory</jndi-name>
    <xa-transaction/>
    <track-connection-by-tx/>
    <rar-name>activemq-rar.rar</rar-name>
   
<connection-definition>javax.jms.QueueConnectionFactory</connection-definition>
    <ServerUrl>vm://localhost</ServerUrl>
    <min-pool-size>1</min-pool-size>
    <max-pool-size>200</max-pool-size>
    <blocking-timeout-millis>30000</blocking-timeout-millis>
    <idle-timeout-minutes>3</idle-timeout-minutes>
  </tx-connection-factory>

  <tx-connection-factory>
    <jndi-name>activemq/TopicConnectionFactory</jndi-name>
    <xa-transaction/>
    <track-connection-by-tx/>
    <rar-name>activemq-rar.rar</rar-name>
   
<connection-definition>javax.jms.TopicConnectionFactory</connection-definition>
    <ServerUrl>vm://localhost</ServerUrl>
    <min-pool-size>1</min-pool-size>
    <max-pool-size>200</max-pool-size>
    <blocking-timeout-millis>30000</blocking-timeout-millis>
    <idle-timeout-minutes>3</idle-timeout-minutes>
  </tx-connection-factory>

  <mbean code="org.jboss.resource.deployment.AdminObject"
name="activemq.topic:name=taskTopic">
    <attribute name="JNDIName">activemq/topic/task</attribute>
    <depends
optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='activemq-rar.rar'</depends>
    <attribute name="Type">javax.jms.Topic</attribute>
    <attribute name="Properties">PhysicalName=topic.task</attribute>
  </mbean>

  <mbean code="org.jboss.resource.deployment.AdminObject"
name="activemq.topic:name=scanTopic">
    <attribute name="JNDIName">activemq/topic/scan</attribute>
    <depends
optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='activemq-rar.rar'</depends>
    <attribute name="Type">javax.jms.Topic</attribute>
    <attribute name="Properties">PhysicalName=topic.scan</attribute>
  </mbean>

  <mbean code="org.jboss.resource.deployment.AdminObject"
name="activemq.topic:name=scannerTopic">
    <attribute name="JNDIName">activemq/topic/scanner</attribute>
    <depends
optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='activemq-rar.rar'</depends>
    <attribute name="Type">javax.jms.Topic</attribute>
    <attribute name="Properties">PhysicalName=topic.scanner</attribute>
  </mbean>

  <mbean code="org.jboss.resource.deployment.AdminObject"
name="activemq.queue:name=fosQueue">
    <attribute name="JNDIName">activemq/queue/FOS</attribute>
    <depends
optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='activemq-rar.rar'</depends>
    <attribute name="Type">javax.jms.Queue</attribute>
    <attribute name="Properties">PhysicalName=queue.FOS</attribute>
  </mbean>

  <mbean code="org.jboss.resource.deployment.AdminObject"
name="activemq.topic:name=fosTopic">
    <attribute name="JNDIName">activemq/topic/FOS</attribute>
    <depends
optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='activemq-rar.rar'</depends>
    <attribute name="Type">javax.jms.Topic</attribute>
    <attribute name="Properties">PhysicalName=topic.FOS</attribute>
  </mbean>
</connection-factories>
*********************************************************************

Contents of broker-config.xml in the rar dir
*********************************************************************
<beans xmlns="http://activemq.apache.org/schema/core">

  <bean xmlns=""
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  <bean xmlns="" id="fosRemoteFactory"
class="com.ibm.mq.jms.MQQueueConnectionFactory">
    <property name="transportType" value="1" />
    <property name="hostName" value="MQHostName" /> 
    <property name="port" value="1415" />
    <property name="queueManager" value="queueManagerName" />
    <property name="channel" value="channelName" />
  </bean>

  <broker useJmx="true" brokerName="jboss-activemq-broker">

    <managementContext>
      <managementContext createConnector="false"/>
    </managementContext>

    <destinationPolicy>
      <policyMap>
        <policyEntries>

          <policyEntry topic="FOO.>">
            <dispatchPolicy>
              <strictOrderDispatchPolicy />
            </dispatchPolicy>
            <subscriptionRecoveryPolicy>
              <lastImageSubscriptionRecoveryPolicy />
            </subscriptionRecoveryPolicy>
          </policyEntry>

        </policyEntries>
      </policyMap>
    </destinationPolicy>


    <persistenceAdapter>
      <journaledJDBC journalLogFiles="5"
dataDirectory="${jboss.server.data.dir}/activemq"/>
    </persistenceAdapter>

    <transportConnectors>
      <transportConnector name="jboss-activemq-broker"
uri="stomp://localhost:61613?trace=true"/>
    </transportConnectors>

    <networkConnectors>
    </networkConnectors>

    <jmsBridgeConnectors>
      <jmsQueueConnector outboundQueueConnectionFactory="#fosRemoteFactory">
        <inboundQueueBridges>
          <inboundQueueBridge inboundQueueName="myInboundQueueName"
localQueueName="FOS" />
        </inboundQueueBridges>
      </jmsQueueConnector>
    </jmsBridgeConnectors>
  </broker>
</beans>
****************************************************************

Contents of ra.xml
****************************************************************
<connector xmlns="http://java.sun.com/xml/ns/j2ee"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
    http://java.sun.com/xml/ns/j2ee/connector_1_5.xsd"
    version="1.5">
    <description>ActiveMQ  inbound and outbound JMS
ResourceAdapter</description>
    <display-name>ActiveMQ JMS Resource Adapter</display-name>
    <vendor-name>activemq.org</vendor-name>
    <eis-type>JMS 1.1</eis-type>
    <resourceadapter-version>1.0</resourceadapter-version>
    <license>
        <description>
          ...
        </description>
        <license-required>true</license-required>
    </license>
    <resourceadapter>
       
<resourceadapter-class>org.apache.activemq.ra.ActiveMQResourceAdapter</resourceadapter-class>
        <config-property>
            <description>
              The URL to the ActiveMQ server that you want this connection
to connect to.  If using
              an embedded broker, this value should be 'vm://localhost'.
            </description>
            <config-property-name>ServerUrl</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
           
<config-property-value><![CDATA[vm://localhost?create=false&async=false]]></config-property-value>
        </config-property>
        <config-property>
            <description>The default user name that will be used to
establish connections to the ActiveMQ server.</description>
            <config-property-name>UserName</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
            <config-property-value>defaultUser</config-property-value>
        </config-property>
        <config-property>
            <description>The default password that will be used to log the
default user into the ActiveMQ server.</description>
            <config-property-name>Password</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
            <config-property-value>defaultPassword</config-property-value>
        </config-property>
        <config-property>
            <description>The client id that will be set on the connection
that is established to the ActiveMQ server.</description>
            <config-property-name>Clientid</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
        </config-property>
        <config-property>
            <description>Boolean to configure if outbound connections should
reuse the inbound connection's session for sending messages.</description>
            <config-property-name>UseInboundSession</config-property-name>
            <config-property-type>java.lang.Boolean</config-property-type>
            <config-property-value>false</config-property-value>
        </config-property>

        <config-property>
            <description>
              Sets the XML configuration file used to configure the embedded
ActiveMQ broker via 
              Spring if using embedded mode.
              
              BrokerXmlConfig is the filename which is assumed to be on the
classpath unless 
              a URL is specified. So a value of foo/bar.xml would be assumed
to be on the 
              classpath whereas file:dir/file.xml would use the file system. 
              Any valid URL string is supported.              
            </description>
            <config-property-name>BrokerXmlConfig</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
           
<config-property-value>xbean:broker-config.xml</config-property-value>
        </config-property>

        <outbound-resourceadapter>
            <connection-definition>
               
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
               
<connectionfactory-interface>javax.jms.ConnectionFactory</connectionfactory-interface>
               
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
               
<connection-interface>javax.jms.Connection</connection-interface>
               
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
            </connection-definition>
            <connection-definition>
               
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
               
<connectionfactory-interface>javax.jms.QueueConnectionFactory</connectionfactory-interface>
               
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
               
<connection-interface>javax.jms.QueueConnection</connection-interface>
               
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
            </connection-definition>
            <connection-definition>
               
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
               
<connectionfactory-interface>javax.jms.TopicConnectionFactory</connectionfactory-interface>
               
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
               
<connection-interface>javax.jms.TopicConnection</connection-interface>
               
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
            </connection-definition>
            <transaction-support>XATransaction</transaction-support>
            <authentication-mechanism>
               
<authentication-mechanism-type>BasicPassword</authentication-mechanism-type>
               
<credential-interface>javax.resource.spi.security.PasswordCredential</credential-interface>
            </authentication-mechanism>
            <reauthentication-support>false</reauthentication-support>
        </outbound-resourceadapter>
        <inbound-resourceadapter>
            <messageadapter>
                <messagelistener>
                   
<messagelistener-type>javax.jms.MessageListener</messagelistener-type>
                    <activationspec>
                       
<activationspec-class>org.apache.activemq.ra.ActiveMQActivationSpec</activationspec-class>
                        
                        <required-config-property>
                           
<config-property-name>destination</config-property-name>
                        </required-config-property>
                        <required-config-property>
                           
<config-property-name>destinationType</config-property-name>
                        </required-config-property>
                        
                    </activationspec>
                </messagelistener>
            </messageadapter>
        </inbound-resourceadapter>
        <adminobject>
            <adminobject-interface>javax.jms.Queue</adminobject-interface>
           
<adminobject-class>org.apache.activemq.command.ActiveMQQueue</adminobject-class>
            <config-property>
                <config-property-name>PhysicalName</config-property-name>
               
<config-property-type>java.lang.String</config-property-type>
            </config-property>
        </adminobject>
        <adminobject>
            <adminobject-interface>javax.jms.Topic</adminobject-interface>
           
<adminobject-class>org.apache.activemq.command.ActiveMQTopic</adminobject-class>
            <config-property>
                <config-property-name>PhysicalName</config-property-name>
               
<config-property-type>java.lang.String</config-property-type>
            </config-property>
        </adminobject>
    </resourceadapter>
</connector>
*************************************************************

Think it's the server url: async=false?  
vm://localhost?create=false&async=false

Sorry for the humongous post.  I tried to trim them down to the bare
essentials.


bsnyder wrote:
> 
> On Wed, Apr 8, 2009 at 8:50 PM, bwarren <brad.warren@usairways.com> wrote:
>>
>> ...
>> http://www.jboss.org/index.html?module=bb&op=viewtopic&t=153782
>> ...
> 
> I've not seen this happen before. What version of ActiveMQ are you
> using? What version of JBoss are you using? Are you embedding ActiveMQ
> inside of JBoss or is ActiveMQ running stand alone? Please describe
> your scenario with more detail and send along the configs.
> 
> Bruce
> 

-- 
View this message in context: http://www.nabble.com/ActiveMQ---JBoss-integration-behaving-badly--tp22963605p22981378.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.