activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From John Toohey ...@parspro.com>
Subject Asynch errors sending transacted messages to 4.1
Date Mon, 05 Mar 2007 19:41:51 GMT
Hi,

My app is using a single-resource transaction to process messages  
from a persistent queue. I read the messages in a transaction,  
process the data, and commit the transaction on success. If my  
business logic fails, I roll-back the transaction. When the message  
gets re-delivered, I try one more time. If it fails again, I send a  
copy of the message to another persistent queue for off-line  
processing, and then commit the original message, to remove it from  
the queue.

However, under the load of about 100 messages, I get the following  
from the message broker :-

DEBUG JournalMessageStore            - Journalled message add for:  
ID:JT-L2.local-57905-1173122363179-1:0:1:1:68, at: 0:952709
DEBUG JournalMessageStore            - Journalled message remove for:  
ID:JT-L2.local-57905-1173122363179-1:0:1:1:68, at: 0:954468
DEBUG JournalMessageStore            - Journalled message add for:  
ID:JT-L2.local-57838-1173121571877-1:3:110:1:1, at: 0:954805
DEBUG JournalMessageStore            - Journalled message add for:  
ID:JT-L2.local-57838-1173121571877-1:0:132:1:1, at: 0:956727
DEBUG BetBrokerReplies               - No subscriptions registered,  
will not dispatch message at this time.
DEBUG JournalMessageStore            - Journalled transacted message  
add for: ID:JT-L2.local-57838-1173121571877-1:3:1:91:1, at: 0:957581
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:91:1:1, at: 0:959948
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:92:1:1, at: 0:960337
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:93:1:1, at: 0:960726
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:94:1:1, at: 0:961115
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:95:1:1, at: 0:961504
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:96:1:1, at: 0:961893
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:97:1:1, at: 0:962282
DEBUG JournalMessageStore            - Journalled transacted message  
remove for: ID:JT-L2.local-57838-1173121571877-1:3:98:1:1, at: 0:962671
DEBUG JournalMessageStore            - Transacted message add commit  
for: ID:JT-L2.local-57838-1173121571877-1:3:1:91:1, at: 0:957581
DEBUG TPRejectedValidBets            - No subscriptions registered,  
will not dispatch message at this time.
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:91:1:1, at: 0:959948
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:92:1:1, at: 0:960337
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:93:1:1, at: 0:960726
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:94:1:1, at: 0:961115
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:95:1:1, at: 0:961504
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:96:1:1, at: 0:961893
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:97:1:1, at: 0:962282
DEBUG JournalMessageStore            - Transacted message remove  
commit for: ID:JT-L2.local-57838-1173121571877-1:3:98:1:1, at: 0:962671
DEBUG JournalMessageStore            - Journalled transacted message  
add for: ID:JT-L2.local-57838-1173121571877-1:3:1:92:1, at: 0:963156
DEBUG Service                        - Async error occurred:  
javax.jms.JMSException: Transaction 'TX:ID:JT- 
L2.local-57838-1173121571877-1:3:188' has not been started.
javax.jms.JMSException: Transaction 'TX:ID:JT- 
L2.local-57838-1173121571877-1:3:188' has not been started.
         at  
org.apache.activemq.broker.TransactionBroker.getTransaction 
(TransactionBroker.java:230)
         at org.apache.activemq.broker.TransactionBroker.send 
(TransactionBroker.java:189)
         at org.apache.activemq.broker.BrokerFilter.send 
(BrokerFilter.java:126)
         at org.apache.activemq.broker.CompositeDestinationBroker.send 
(CompositeDestinationBroker.java:98)
         at org.apache.activemq.broker.MutableBrokerFilter.send 
(MutableBrokerFilter.java:136)
         at  
org.apache.activemq.broker.TransportConnection.processMessage 
(TransportConnection.java:480)
         at org.apache.activemq.command.ActiveMQMessage.visit 
(ActiveMQMessage.java:604)
         at org.apache.activemq.broker.TransportConnection.service 
(TransportConnection.java:284)
         at org.apache.activemq.broker.TransportConnection$1.onCommand 
(TransportConnection.java:177)
         at org.apache.activemq.transport.TransportFilter.onCommand 
(TransportFilter.java:65)
         at  
org.apache.activemq.transport.WireFormatNegotiator.onCommand 
(WireFormatNegotiator.java:133)
         at org.apache.activemq.transport.InactivityMonitor.onCommand 
(InactivityMonitor.java:122)
         at org.apache.activemq.transport.TransportSupport.doConsume 
(TransportSupport.java:84)
         at org.apache.activemq.transport.tcp.TcpTransport.run 
(TcpTransport.java:137)
         at java.lang.Thread.run(Thread.java:613)


This is often followed by :-

DEBUG JournalMessageStore            - Transacted message add commit  
for: ID:JT-L2.local-57838-1173121571877-1:9:1:3:1, at: 0:1238329
DEBUG TPRejectedValidBets            - No subscriptions registered,  
will not dispatch message at this time.
DEBUG Transport                      - Transport failed:  
java.io.EOFException
java.io.EOFException
         at java.io.DataInputStream.readInt(DataInputStream.java:358)
         at org.apache.activemq.openwire.OpenWireFormat.unmarshal 
(OpenWireFormat.java:267)
         at org.apache.activemq.transport.tcp.TcpTransport.readCommand 
(TcpTransport.java:156)
         at org.apache.activemq.transport.tcp.TcpTransport.run 
(TcpTransport.java:136)
         at java.lang.Thread.run(Thread.java:613)
DEBUG TransportConnection            - Stopping connection: / 
127.0.0.1:57906


I'm using AMQ 4.1 and Mule 1.3.3.

Any help or pointers would be appreciated.



- JT



Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message