Return-Path: Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org Received: (qmail 49401 invoked from network); 20 Apr 2006 06:18:01 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 20 Apr 2006 06:18:01 -0000 Received: (qmail 22241 invoked by uid 500); 20 Apr 2006 06:18:01 -0000 Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org Received: (qmail 22104 invoked by uid 500); 20 Apr 2006 06:18:00 -0000 Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-users@geronimo.apache.org Delivered-To: mailing list activemq-users@geronimo.apache.org Received: (qmail 22095 invoked by uid 99); 20 Apr 2006 06:18:00 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Apr 2006 23:18:00 -0700 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: domain of james.strachan@gmail.com designates 66.249.92.170 as permitted sender) Received: from [66.249.92.170] (HELO uproxy.gmail.com) (66.249.92.170) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Apr 2006 23:17:59 -0700 Received: by uproxy.gmail.com with SMTP id m3so66517ugc for ; Wed, 19 Apr 2006 23:17:38 -0700 (PDT) DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws; s=beta; d=gmail.com; h=received:message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references; b=Q8HqlRTzedvxX/nyQ/C0FvhSEFAolMn7avp2w4ZsVwjhhDnT1cCdIpsjmkKgoUW9H0TvYWm5m+Q5BHOKhuV7bdC9N+NSox9yrS+2Q+QLqs0T7g+hYxbcPSqELsp+1IwYwEVFMj/80RKsYo8IlAnNp5zlovDt6/Kx/YGdliHbVQg= Received: by 10.78.18.3 with SMTP id 3mr12145hur; Wed, 19 Apr 2006 23:17:38 -0700 (PDT) Received: by 10.78.27.13 with HTTP; Wed, 19 Apr 2006 23:17:38 -0700 (PDT) Message-ID: Date: Thu, 20 Apr 2006 07:17:38 +0100 From: "James Strachan" To: activemq-users@geronimo.apache.org Subject: Re: Endpoint failed to process message In-Reply-To: <4001377.post@talk.nabble.com> MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Content-Disposition: inline References: <4001377.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Whats your JDBC connection pool configuration? It looks like some issue with MySQL or the DataSource used with MySQL On 4/20/06, Wayne1285 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 sta= rts > throwing errors. > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D > DEBUG Work started: javax.resource.spi.work.WorkEvent[source=3DWork > :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=3D' date=3D"2006-04-05T16:25:24-0500" player=3D"AD_BOX_014"> action=3D"played" id=3D"Sample5" contract=3D"Contract04" position=3D"1" /= >' > -- 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=3Dorg.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.04= 7AM > CDT java.lang.RuntimeException: Endpoint after delivery notification fail= ure > at > org.apache.activemq.ra.ServerSessionImpl.afterDelivery(ServerSessionImpl.= java:216) > at org.apache.activemq.ActiveMQSession.run(ActiveMQSession.java:7= 33) > at org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl= .java:163) > at > org.apache.geronimo.connector.work.WorkerContext.run(WorkerContext.java:2= 91) > at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(Unk= nown > 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(LocalTransactionEndpoin= t.java:52) > at > org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.afterDel= ivery(MessageEndpointProxy.java:125) > at > org.apache.activemq.ra.MessageEndpointProxy.afterDelivery(MessageEndpoint= Proxy.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:1= 56) > at com.mysql.jdbc.MysqlIO.(MysqlIO.java:284) > at com.mysql.jdbc.Connection.createNewIO(Connection.java:2541) > at com.mysql.jdbc.Connection.(Connection.java:1474) > at > com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:266= ) > at > com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSour= ce.java:425) > at > com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSour= ce.java:140) > at > com.mysql.jdbc.jdbc2.optional.MysqlDataSource.getConnection(MysqlDataSour= ce.java:110) > at > org.apache.activemq.store.jdbc.TransactionContext.getConnection(Transacti= onContext.java:54) > at > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRemoveMessage= (DefaultJDBCAdapter.java:302) > at > org.apache.activemq.store.jdbc.JDBCMessageStore.removeMessage(JDBCMessage= Store.java:138) > at > org.apache.activemq.store.memory.MemoryTransactionStore$4.run(MemoryTrans= actionStore.java:242) > at > org.apache.activemq.store.memory.MemoryTransactionStore$Tx.commit(MemoryT= ransactionStore.java:98) > at > org.apache.activemq.store.memory.MemoryTransactionStore.commit(MemoryTran= sactionStore.java:170) > at > org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.= java:67) > at > org.apache.activemq.broker.TransactionBroker.commitTransaction(Transactio= nBroker.java:153) > at > org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.ja= va:77) > at > org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.ja= va:77) > at > org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableB= rokerFilter.java:89) > at > org.apache.activemq.broker.AbstractConnection.processCommitTransactionOne= Phase(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(TransportConne= ction.java:62) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrel= ator.java:93) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.j= ava:70) > at > org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNe= gotiator.java:114) > at > org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonit= or.java:122) > at > org.apache.activemq.transport.TransportLogger.onCommand(TransportLogger.j= ava: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.j= ava: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: > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D > > After this, all the processing fails. > > If I restart the process it processes 100s of messages again, and then ru= ns > into this problem again. > > Any ideas? > -- > View this message in context: http://www.nabble.com/Endpoint-failed-to-pr= ocess-message-t1478529.html#a4001377 > Sent from the ActiveMQ - User forum at Nabble.com. > > -- James ------- http://radio.weblogs.com/0112098/