Whats your JDBC connection pool configuration? It looks like some issue with MySQL or the DataSource used with MySQL
On 4/20/06, Wayne1285 <[EMAIL PROTECTED]> 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: > [EMAIL PROTECTED] > -- 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/
