activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Outbound XA on ActiveMQ and JBoss
Date Thu, 13 Jul 2006 13:53:46 GMT
I'd recommend upgrading to 4.0.1 as numerous issues with JCA have been
resolved since 3.2 was out last year

On 7/13/06, PeterNilsson <peter.nilsson.se@gmail.com> wrote:
>
> Hi,
>
> I am trying to run XA for outbound messages on ActiveMQ (3.2) with JBoss
> (4.02 transaction manager. I haven't had any luch with Jencks so now I try
> to connect to ActiveMQ diretly.
> The rar is deployed with xa-transaction specified but according to the log
> below the message is not XA transacted.
> Any ideas what more is needed?
>
>    TIA,
>
>    Peter
>
> 2006-07-13 11:16:00,332 DEBUG [com.omxgroup.esb.component.JmsOutBinding]
> Sending message to XA_ROUTED
> 2006-07-13 11:16:00,332 DEBUG
> [org.jboss.resource.connectionmanager.IdleRemover] internalRegisterPool:
> registering pool with interval 900000 old interval: 450000
> 2006-07-13 11:16:00,352 DEBUG [org.activemq.broker.impl.BrokerClientImpl]
> brokerConnectorConnector client initialized
> 2006-07-13 11:16:00,352 DEBUG [org.activemq.broker.impl.BrokerConnectorImpl]
> Starting new client: brokerConnector-client:(7608442) : TcpTransportChannel:
> Socket[addr=/127.0.0.1,port=2662,localport=61616]
> 2006-07-13 11:16:00,352 DEBUG
> [org.activemq.transport.tcp.TcpTransportChannel] TCP consumer thread
> starting
> 2006-07-13 11:16:00,352 INFO  [org.activemq.ActiveMQConnection] channel
> status changed: Channel: TcpTransportChannel:
> Socket[addr=localhost/127.0.0.1,port=61616,localport=2662] has connected
> 2006-07-13 11:16:00,362 DEBUG
> [org.activemq.transport.tcp.TcpTransportChannel] TCP consumer thread
> starting
> 2006-07-13 11:16:00,362 DEBUG
> [org.activemq.transport.TransportChannelSupport] TcpTransportChannel:
> Socket[addr=/127.0.0.1,port=2662,localport=61616] using wire format version:
> 3
> 2006-07-13 11:16:00,362 DEBUG [org.activemq.broker.CommandTrace] broker for
> null received: ACTIVEMQ_CONNECTION_INFO: id = 2 ConnectionInfo{ clientId =
> 'ID:SE10LT1240-2613-1152782046529-236:0' , userName = 'defaultUser' ,
> hostName = 'SE10LT1240' , clientVersion = '3.2' , wireFormatVersion = 3,
> startTime = 1152782160352, started = false, closed = false, properties =
> {noDelay=false} }
> 2006-07-13 11:16:00,362 INFO  [org.activemq.broker.impl.BrokerContainerImpl]
> Adding new client: ID:SE10LT1240-2613-1152782046529-236:0 on transport:
> TcpTransportChannel: Socket[addr=/127.0.0.1,port=2662,localport=61616]
> 2006-07-13 11:16:00,362 DEBUG [org.activemq.broker.CommandTrace] broker for
> ID:SE10LT1240-2613-1152782046529-236:0 sending: RECEIPT_INFO: id = 1
> Receipt{ brokerMessageCapacity = 100, correlationId = '2' , brokerName =
> 'ID:SE10LT1240-2613-1152782046529-1:0' , clusterName = 'default' , exception
> = null, failed = false }
> 2006-07-13 11:16:00,372 DEBUG [org.activemq.broker.CommandTrace] broker for
> ID:SE10LT1240-2613-1152782046529-236:0 received: SESSION_INFO: id = 3
> SessionInfo{ clientId = 'ID:SE10LT1240-2613-1152782046529-236:0' , sessionId
> = '1' , startTime = 1152782160372, started = true }
> 2006-07-13 11:16:00,372 DEBUG [org.springframework.jms.core.JmsTemplate]
> Executing callback on JMS Session [org.activemq.ra.JMSSessionProxy@1f070e8]
> from connection [org.activemq.ra.JMSConnectionProxy@e16021]
> 2006-07-13 11:16:00,382 DEBUG [org.activemq.broker.CommandTrace] broker for
> ID:SE10LT1240-2613-1152782046529-236:0 received: PRODUCER_INFO: id = 4
> ProducerInfo{ clientId = 'ID:SE10LT1240-2613-1152782046529-236:0' ,
> destination = XA_ROUTED, producerId = '1' , sessionId = '1' , startTime =
> 1152782160372, started = true }
> 2006-07-13 11:16:00,382 DEBUG [org.springframework.jms.core.JmsTemplate]
> Sending created message [ACTIVEMQ_TEXT_MESSAGE: id = 0 ActiveMQMessage{ ,
> jmsMessageID = null, bodyAsBytes = null, readOnlyMessage = false,
> jmsClientID = 'null' , jmsCorrelationID = 'null' , jmsDestination = null,
> jmsReplyTo = null, jmsDeliveryMode = 2, jmsRedelivered = false, jmsType =
> 'null' , jmsExpiration = 0, jmsPriority = 4, jmsTimestamp = 0, properties =
> {JMS_DESTINATION=XA_ROUTED}, readOnlyProperties = false, entryBrokerName =
> 'null' , entryClusterName = 'null' , consumerNos = null, transactionId =
> 'null' , xaTransacted = false, consumerIdentifer = 'null' , messageConsumed
> = false, transientConsumed = false, sequenceNumber = 0, deliveryCount = 1,
> dispatchedFromDLQ = false, messageAcknowledge = null, jmsMessageIdentity =
> null, producerKey = null }, text = <?xml version="1.0"
> encoding="UTF-8"?><ns3:PartyAndPartyRolesNDO
> xmlns:ns3="http://www.omxgroup.com/bb/bong/ndo/party"
> xmlns:ns2="http://www.omxgroup.com/bb/bong/ws/xatester"><Individual><Id><IdentifierType>SPS</IdentifierType><ObjectType>PARTY</ObjectType><Value>600</Value></Id><Name>Boris
> Becker</Name><Address><Type>OFFICIAL_ADDRESS</Type><Line1>Upplandsgatan
> 56</Line1><Line2 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><Line3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><PostalCode>113
> 28</PostalCode><City>Stockholm</City><Country>SE</Country></Address><Status>NORMAL</Status><OwnedBy
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><TaxStatus>NORMAL</TaxStatus><TaxPercentage>0.45</TaxPercentage><LegalEntity
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><ManagedBy><IdentifierType>SPS</IdentifierType><ObjectType>PARTY_ROLE</ObjectType><Value>0</Value></ManagedBy><ReportLanguage>EN</ReportLanguage><Template>false</Template><MemberOf><Id><IdentifierType>SPS</IdentifierType><ObjectType>CATEGORY</ObjectType><Value>0</Value></Id></MemberOf><ExtraIdentifiers><IdentifierType>SE_PIN</IdentifierType><ObjectType>PARTY</ObjectType><Value>681201-5555</Value></ExtraIdentifiers><Firstname>Boris</Firstname><Lastname>Becker</Lastname><Title
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><TaxDomicile>SE</TaxDomicile><Nationality>SE</Nationality><PlaceOfBirth>D?sseldorf</PlaceOfBirth><DateOfBirth>1974-01-03</DateOfBirth></Individual><CustomerRole><Id><IdentifierType>SPS</IdentifierType><ObjectType>PARTY_ROLE</ObjectType><Value>601</Value></Id><Status>ACTIVE</Status><Comment
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><Verified>false</Verified><ContactInfo
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><AcceptsMarketInfo>false</AcceptsMarketInfo></CustomerRole></ns3:PartyAndPartyRolesNDO>]
> 2006-07-13 11:16:00,382 DEBUG [org.activemq.ActiveMQSession] Sending
> message: ACTIVEMQ_TEXT_MESSAGE: id = 0 ActiveMQMessage{ , jmsMessageID =
> ID:SE10LT1240-2613-1152782046529-244:0, bodyAsBytes =
> org.activemq.io.util.ByteArray@63c132, readOnlyMessage = false, jmsClientID
> = 'ID:SE10LT1240-2613-1152782046529-236:0' , jmsCorrelationID = 'null' ,
> jmsDestination = XA_ROUTED, jmsReplyTo = null, jmsDeliveryMode = 2,
> jmsRedelivered = false, jmsType = 'null' , jmsExpiration = 0, jmsPriority =
> 4, jmsTimestamp = 1152782160382, properties = {JMS_DESTINATION=XA_ROUTED},
> readOnlyProperties = false, entryBrokerName = 'null' , entryClusterName =
> 'null' , consumerNos = null, transactionId = 'null' , xaTransacted = false,
> consumerIdentifer = 'null' , messageConsumed = false, transientConsumed =
> false, sequenceNumber = 0, deliveryCount = 1, dispatchedFromDLQ = false,
> messageAcknowledge = null, jmsMessageIdentity = null, producerKey =
> ID:SE10LT1240-2613-1152782046529-244: }, text = <?xml version="1.0"
> encoding="UTF-8"?><ns3:PartyAndPartyRolesNDO
> xmlns:ns3="http://www.omxgroup.com/bb/bong/ndo/party"
> xmlns:ns2="http://www.omxgroup.com/bb/bong/ws/xatester"><Individual><Id><IdentifierType>SPS</IdentifierType><ObjectType>PARTY</ObjectType><Value>600</Value></Id><Name>Boris
> Becker</Name><Address><Type>OFFICIAL_ADDRESS</Type><Line1>Upplandsgatan
> 56</Line1><Line2 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><Line3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><PostalCode>113
> 28</PostalCode><City>Stockholm</City><Country>SE</Country></Address><Status>NORMAL</Status><OwnedBy
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><TaxStatus>NORMAL</TaxStatus><TaxPercentage>0.45</TaxPercentage><LegalEntity
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><ManagedBy><IdentifierType>SPS</IdentifierType><ObjectType>PARTY_ROLE</ObjectType><Value>0</Value></ManagedBy><ReportLanguage>EN</ReportLanguage><Template>false</Template><MemberOf><Id><IdentifierType>SPS</IdentifierType><ObjectType>CATEGORY</ObjectType><Value>0</Value></Id></MemberOf><ExtraIdentifiers><IdentifierType>SE_PIN</IdentifierType><ObjectType>PARTY</ObjectType><Value>681201-5555</Value></ExtraIdentifiers><Firstname>Boris</Firstname><Lastname>Becker</Lastname><Title
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><TaxDomicile>SE</TaxDomicile><Nationality>SE</Nationality><PlaceOfBirth>D?sseldorf</PlaceOfBirth><DateOfBirth>1974-01-03</DateOfBirth></Individual><CustomerRole><Id><IdentifierType>SPS</IdentifierType><ObjectType>PARTY_ROLE</ObjectType><Value>601</Value></Id><Status>ACTIVE</Status><Comment
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><Verified>false</Verified><ContactInfo
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><AcceptsMarketInfo>false</AcceptsMarketInfo></CustomerRole></ns3:PartyAndPartyRolesNDO>
> 2006-07-13 11:16:00,382 DEBUG [org.activemq.broker.CommandTrace] broker for
> ID:SE10LT1240-2613-1152782046529-236:0 received: ACTIVEMQ_TEXT_MESSAGE: id =
> 0 ActiveMQMessage{ , jmsMessageID = null, bodyAsBytes =
> org.activemq.io.util.ByteArray@9a288b, readOnlyMessage = false, jmsClientID
> = 'ID:SE10LT1240-2613-1152782046529-236:0' , jmsCorrelationID = 'null' ,
> jmsDestination = XA_ROUTED, jmsReplyTo = null, jmsDeliveryMode = 2,
> jmsRedelivered = false, jmsType = 'null' , jmsExpiration = 0, jmsPriority =
> 4, jmsTimestamp = 1152782160382, properties = {JMS_DESTINATION=XA_ROUTED},
> readOnlyProperties = false, entryBrokerName = 'null' , entryClusterName =
> 'null' , consumerNos = null, transactionId = 'null' , xaTransacted = false,
> consumerIdentifer = 'null' , messageConsumed = false, transientConsumed =
> false, sequenceNumber = 0, deliveryCount = 1, dispatchedFromDLQ = false,
> messageAcknowledge = null, jmsMessageIdentity = null, producerKey =
> ID:SE10LT1240-2613-1152782046529-244: }, text = <?xml version="1.0"
> encoding="UTF-8"?><ns3:PartyAndPartyRolesNDO
> xmlns:ns3="http://www.omxgroup.com/bb/bong/ndo/party"
> xmlns:ns2="http://www.omxgroup.com/bb/bong/ws/xatester"><Individual><Id><IdentifierType>SPS</IdentifierType><ObjectType>PARTY</ObjectType><Value>600</Value></Id><Name>Boris
> Becker</Name><Address><Type>OFFICIAL_ADDRESS</Type><Line1>Upplandsgatan
> 56</Line1><Line2 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><Line3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><PostalCode>113
> 28</PostalCode><City>Stockholm</City><Country>SE</Country></Address><Status>NORMAL</Status><OwnedBy
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><TaxStatus>NORMAL</TaxStatus><TaxPercentage>0.45</TaxPercentage><LegalEntity
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><ManagedBy><IdentifierType>SPS</IdentifierType><ObjectType>PARTY_ROLE</ObjectType><Value>0</Value></ManagedBy><ReportLanguage>EN</ReportLanguage><Template>false</Template><MemberOf><Id><IdentifierType>SPS</IdentifierType><ObjectType>CATEGORY</ObjectType><Value>0</Value></Id></MemberOf><ExtraIdentifiers><IdentifierType>SE_PIN</IdentifierType><ObjectType>PARTY</ObjectType><Value>681201-5555</Value></ExtraIdentifiers><Firstname>Boris</Firstname><Lastname>Becker</Lastname><Title
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><TaxDomicile>SE</TaxDomicile><Nationality>SE</Nationality><PlaceOfBirth>D?sseldorf</PlaceOfBirth><DateOfBirth>1974-01-03</DateOfBirth></Individual><CustomerRole><Id><IdentifierType>SPS</IdentifierType><ObjectType>PARTY_ROLE</ObjectType><Value>601</Value></Id><Status>ACTIVE</Status><Comment
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><Verified>false</Verified><ContactInfo
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:nil="true"/><AcceptsMarketInfo>false</AcceptsMarketInfo></CustomerRole></ns3:PartyAndPartyRolesNDO>
> 2006-07-13 11:16:00,392 DEBUG
> [org.activemq.store.journal.JournalMessageStore] Journalled message add:
> ID:SE10LT1240-2613-1152782046529-244:0 at 0:181685
> 2006-07-13 11:16:00,402 DEBUG [org.activemq.broker.CommandTrace] broker for
> ID:SE10LT1240-2613-1152782046529-236:0 received: PRODUCER_INFO: id = 6
> ProducerInfo{ clientId = 'ID:SE10LT1240-2613-1152782046529-236:0' ,
> destination = XA_ROUTED, producerId = '1' , sessionId = '1' , startTime =
> 1152782160372, started = false }
> 2006-07-13 11:16:00,402 DEBUG [org.activemq.broker.CommandTrace] broker for
> ID:SE10LT1240-2613-1152782046529-236:0 received: SESSION_INFO: id = 7
> SessionInfo{ clientId = 'ID:SE10LT1240-2613-1152782046529-236:0' , sessionId
> = '1' , startTime = 1152782160372, started = false }
> 2006-07-13 11:16:00,402 DEBUG [org.activemq.broker.CommandTrace] broker for
> ID:SE10LT1240-2613-1152782046529-236:0 received: UNKNOWN PACKET TYPE: 33: id
> = 8 ClenaupConnectionAndSessionInfo{ clientId =
> 'ID:SE10LT1240-2613-1152782046529-236:0' , sessionId = '0'  }
> 2006-07-13 11:16:00,402 INFO  [org.activemq.broker.impl.BrokerContainerImpl]
> Removing client: ID:SE10LT1240-2613-1152782046529-236:0 on transport:
> TcpTransportChannel: Socket[addr=/127.0.0.1,port=2662,localport=61616]
> 2006-07-13 11:16:00,402 DEBUG [org.activemq.broker.impl.BrokerClientImpl]
> brokerConnector-client:(7608442) ID:SE10LT1240-2613-1152782046529-236:0:
> TcpTransportChannel: Socket[addr=/127.0.0.1,port=2662,localport=61616] has
> stopped
> 2006-07-13 11:16:00,402 DEBUG [com.omxgroup.esb.component.XsltRouter]
> Passing acknowledge to consumer
> 2006-07-13 11:16:00,402 DEBUG
> [org.springframework.transaction.support.TransactionSynchronizationManager]
> Removed value [kodo.jdbc.ee.JDBCConnectionFactory@d1d45634] for key [class
> com.omxgroup.bb.bong.framework.persistence.JdoPmFactorySingleton] from
> thread [Thread-184]
>
> Configuration:
>
> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"
> abstract="true">
>   <property name="connectionFactory">
>     <ref local="jmsConnectionFactory"/>
>   </property>
>   <property name="pubSubDomain" value="false"/>
> </bean>
>
> <bean id="jmsConnectionFactory"
> class="org.springframework.jndi.JndiObjectFactoryBean">
>   <property name="jndiName">
>     <value>java:/activemq/QueueConnectionFactory</value>
>   </property>
> </bean>
>
> <?xml version="1.0" encoding="UTF-8"?>
> <!DOCTYPE connection-factories PUBLIC "-//JBoss//DTD JBOSS JCA Config
> 1.5//EN" "http://www.jboss.org/j2ee/dtd/jboss-ds_1_5.dtd">
> <connection-factories>
>   <tx-connection-factory>
>     <jndi-name>activemq/QueueConnectionFactory</jndi-name>
>     <xa-transaction/>
>     <track-connection-by-tx/>
>     <rar-name>activemq-ra-3.2.rar</rar-name>
>
> <connection-definition>javax.jms.QueueConnectionFactory</connection-definition>
>   </tx-connection-factory>
> </connection-factories>
> --
> View this message in context: http://www.nabble.com/Outbound-XA-on-ActiveMQ-and-JBoss-tf1936710.html#a5306361
> Sent from the ActiveMQ - User forum at Nabble.com.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message