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