You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Wayne1285 <Wa...@hotmail.com> on 2006/04/20 07:26:32 UTC
Endpoint failed to process message
I am running ActiveMQ-4.0-RC3, ActiveMQ-ra-4.0-RC3 and Jencks 1.1.2,
processing queued messages in a MySQL 5.0 database.
Processes starts and runs through 100's of messages and then suddenly starts
throwing errors.
==================================================
DEBUG Work started: javax.resource.spi.work.WorkEvent[source=Work
:ServerSessionImpl:8] -- Thu 2006.04.20 12:07:20.001AM CDT
DEBUG Running -- Thu 2006.04.20 12:07:20.001AM CDT
DEBUG run loop start -- Thu 2006.04.20 12:07:20.001AM CDT
DEBUG PlayerActivityHandler.processMessage() Message='<played
date="2006-04-05T16:25:24-0500" player="AD_BOX_014"><scheduledSpot
action="played" id="Sample5" contract="Contract04" position="1" /></played>'
-- Thu 2006.04.20 12:07:20.001AM CDT
DEBUG UploadProcessFileImpl.appendToFile() Just wrote
"2006-04-05T16:25:24-0500, AD_BOX_014,1,Sample5,Contract04" to
C:\sample\data\playedTunes.txt -- Thu 2006.04.20 12:07:20.001AM CDT
DEBUG ServerSession requested. -- Thu 2006.04.20 12:07:20.016AM CDT
DEBUG Using idle session: ServerSessionImpl:7 -- Thu 2006.04.20
12:07:20.016AM CDT
DEBUG Starting run. -- Thu 2006.04.20 12:07:20.016AM CDT
DEBUG Work accepted:
javax.resource.spi.work.WorkEvent[source=org.apache.geronimo.connector.work.GeronimoWorkManager@3ae941]
-- Thu 2006.04.20 12:07:20.016AM CDT
DEBUG Endpoint failed to process message. -- Thu 2006.04.20 12:07:20.047AM
CDT java.lang.RuntimeException: Endpoint after delivery notification failure
at
org.apache.activemq.ra.ServerSessionImpl.afterDelivery(ServerSessionImpl.java:216)
at org.apache.activemq.ActiveMQSession.run(ActiveMQSession.java:733)
at org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:163)
at
org.apache.geronimo.connector.work.WorkerContext.run(WorkerContext.java:291)
at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(Unknown
Source)
at java.lang.Thread.run(Unknown Source)
Caused by: commit failed.
at
org.apache.activemq.ra.LocalAndXATransaction.commit(LocalAndXATransaction.java:59)
at
org.jencks.LocalTransactionEndpoint.afterDelivery(LocalTransactionEndpoint.java:52)
at
org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.afterDelivery(MessageEndpointProxy.java:125)
at
org.apache.activemq.ra.MessageEndpointProxy.afterDelivery(MessageEndpointProxy.java:64)
at
org.apache.activemq.ra.ServerSessionImpl.afterDelivery(ServerSessionImpl.java:214)
... 5 more
Caused by: javax.jms.JMSException: Communications link failure due to
underlying exception:
** BEGIN NESTED EXCEPTION **
java.net.SocketException
MESSAGE: java.net.BindException: Address already in use: connect
STACKTRACE:
java.net.SocketException: java.net.BindException: Address already in use:
connect
at
com.mysql.jdbc.StandardSocketFactory.connect(StandardSocketFactory.java:156)
at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:284)
at com.mysql.jdbc.Connection.createNewIO(Connection.java:2541)
at com.mysql.jdbc.Connection.<init>(Connection.java:1474)
at
com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:266)
at
com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSource.java:425)
at
com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSource.java:140)
at
com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSource.java:110)
at
org.apache.activemq.store.jdbc.TransactionContext.getConnection(TransactionContext.java:54)
at
org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRemoveMessage(DefaultJDBCAdapter.java:302)
at
org.apache.activemq.store.jdbc.JDBCMessageStore.removeMessage(JDBCMessageStore.java:138)
at
org.apache.activemq.store.memory.MemoryTransactionStore$4.run(MemoryTransactionStore.java:242)
at
org.apache.activemq.store.memory.MemoryTransactionStore$Tx.commit(MemoryTransactionStore.java:98)
at
org.apache.activemq.store.memory.MemoryTransactionStore.commit(MemoryTransactionStore.java:170)
at
org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:67)
at
org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:153)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:77)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:77)
at
org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:89)
at
org.apache.activemq.broker.AbstractConnection.processCommitTransactionOnePhase(AbstractConnection.java:297)
at
org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:98)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:196)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:93)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:70)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportLogger.onCommand(TransportLogger.java:58)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:139)
at java.lang.Thread.run(Unknown Source)
** END NESTED EXCEPTION **
Last packet sent to the server was 0 ms ago.
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:45)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1119)
at
org.apache.activemq.TransactionContext.commit(TransactionContext.java:259)
at
org.apache.activemq.ra.LocalAndXATransaction.commit(LocalAndXATransaction.java:57)
... 9 more
Caused by: java.io.IOException: Communications link failure due to
underlying exception:
==================================================
After this, all the processing fails.
If I restart the process it processes 100s of messages again, and then runs
into this problem again.
Any ideas?
--
View this message in context: http://www.nabble.com/Endpoint-failed-to-process-message-t1478529.html#a4001377
Sent from the ActiveMQ - User forum at Nabble.com.
Re: Endpoint failed to process message
Posted by James Strachan <ja...@gmail.com>.
Whats your JDBC connection pool configuration? It looks like some
issue with MySQL or the DataSource used with MySQL
On 4/20/06, Wayne1285 <Wa...@hotmail.com> wrote:
>
> I am running ActiveMQ-4.0-RC3, ActiveMQ-ra-4.0-RC3 and Jencks 1.1.2,
> processing queued messages in a MySQL 5.0 database.
> Processes starts and runs through 100's of messages and then suddenly starts
> throwing errors.
> ==================================================
> DEBUG Work started: javax.resource.spi.work.WorkEvent[source=Work
> :ServerSessionImpl:8] -- Thu 2006.04.20 12:07:20.001AM CDT
> DEBUG Running -- Thu 2006.04.20 12:07:20.001AM CDT
> DEBUG run loop start -- Thu 2006.04.20 12:07:20.001AM CDT
> DEBUG PlayerActivityHandler.processMessage() Message='<played
> date="2006-04-05T16:25:24-0500" player="AD_BOX_014"><scheduledSpot
> action="played" id="Sample5" contract="Contract04" position="1" /></played>'
> -- Thu 2006.04.20 12:07:20.001AM CDT
> DEBUG UploadProcessFileImpl.appendToFile() Just wrote
> "2006-04-05T16:25:24-0500, AD_BOX_014,1,Sample5,Contract04" to
> C:\sample\data\playedTunes.txt -- Thu 2006.04.20 12:07:20.001AM CDT
> DEBUG ServerSession requested. -- Thu 2006.04.20 12:07:20.016AM CDT
> DEBUG Using idle session: ServerSessionImpl:7 -- Thu 2006.04.20
> 12:07:20.016AM CDT
> DEBUG Starting run. -- Thu 2006.04.20 12:07:20.016AM CDT
> DEBUG Work accepted:
> javax.resource.spi.work.WorkEvent[source=org.apache.geronimo.connector.work.GeronimoWorkManager@3ae941]
> -- Thu 2006.04.20 12:07:20.016AM CDT
> DEBUG Endpoint failed to process message. -- Thu 2006.04.20 12:07:20.047AM
> CDT java.lang.RuntimeException: Endpoint after delivery notification failure
> at
> org.apache.activemq.ra.ServerSessionImpl.afterDelivery(ServerSessionImpl.java:216)
> at org.apache.activemq.ActiveMQSession.run(ActiveMQSession.java:733)
> at org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:163)
> at
> org.apache.geronimo.connector.work.WorkerContext.run(WorkerContext.java:291)
> at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(Unknown
> Source)
> at java.lang.Thread.run(Unknown Source)
> Caused by: commit failed.
> at
> org.apache.activemq.ra.LocalAndXATransaction.commit(LocalAndXATransaction.java:59)
> at
> org.jencks.LocalTransactionEndpoint.afterDelivery(LocalTransactionEndpoint.java:52)
> at
> org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.afterDelivery(MessageEndpointProxy.java:125)
> at
> org.apache.activemq.ra.MessageEndpointProxy.afterDelivery(MessageEndpointProxy.java:64)
> at
> org.apache.activemq.ra.ServerSessionImpl.afterDelivery(ServerSessionImpl.java:214)
> ... 5 more
> Caused by: javax.jms.JMSException: Communications link failure due to
> underlying exception:
>
> ** BEGIN NESTED EXCEPTION **
>
> java.net.SocketException
> MESSAGE: java.net.BindException: Address already in use: connect
>
> STACKTRACE:
>
> java.net.SocketException: java.net.BindException: Address already in use:
> connect
> at
> com.mysql.jdbc.StandardSocketFactory.connect(StandardSocketFactory.java:156)
> at com.mysql.jdbc.MysqlIO.<init>(MysqlIO.java:284)
> at com.mysql.jdbc.Connection.createNewIO(Connection.java:2541)
> at com.mysql.jdbc.Connection.<init>(Connection.java:1474)
> at
> com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:266)
> at
> com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSource.java:425)
> at
> com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSource.java:140)
> at
> com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSource.java:110)
> at
> org.apache.activemq.store.jdbc.TransactionContext.getConnection(TransactionContext.java:54)
> at
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRemoveMessage(DefaultJDBCAdapter.java:302)
> at
> org.apache.activemq.store.jdbc.JDBCMessageStore.removeMessage(JDBCMessageStore.java:138)
> at
> org.apache.activemq.store.memory.MemoryTransactionStore$4.run(MemoryTransactionStore.java:242)
> at
> org.apache.activemq.store.memory.MemoryTransactionStore$Tx.commit(MemoryTransactionStore.java:98)
> at
> org.apache.activemq.store.memory.MemoryTransactionStore.commit(MemoryTransactionStore.java:170)
> at
> org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:67)
> at
> org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:153)
> at
> org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:77)
> at
> org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:77)
> at
> org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:89)
> at
> org.apache.activemq.broker.AbstractConnection.processCommitTransactionOnePhase(AbstractConnection.java:297)
> at
> org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:98)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:196)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:93)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:70)
> at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
> at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
> at
> org.apache.activemq.transport.TransportLogger.onCommand(TransportLogger.java:58)
> at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:139)
> at java.lang.Thread.run(Unknown Source)
>
>
> ** END NESTED EXCEPTION **
>
>
>
> Last packet sent to the server was 0 ms ago.
> at
> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:45)
> at
> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1119)
> at
> org.apache.activemq.TransactionContext.commit(TransactionContext.java:259)
> at
> org.apache.activemq.ra.LocalAndXATransaction.commit(LocalAndXATransaction.java:57)
> ... 9 more
> Caused by: java.io.IOException: Communications link failure due to
> underlying exception:
> ==================================================
>
> After this, all the processing fails.
>
> If I restart the process it processes 100s of messages again, and then runs
> into this problem again.
>
> Any ideas?
> --
> View this message in context: http://www.nabble.com/Endpoint-failed-to-process-message-t1478529.html#a4001377
> Sent from the ActiveMQ - User forum at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/