activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From PeterNilsson <peter.nilsson...@gmail.com>
Subject Outbound XA on ActiveMQ and JBoss
Date Thu, 13 Jul 2006 11:42:00 GMT

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.


Mime
View raw message