[ https://issues.apache.org/jira/browse/QPID-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15234985#comment-15234985 ]
ASF subversion and git services commented on QPID-7154: ------------------------------------------------------- Commit 1738576 from [~k-wall] in branch 'java/branches/6.0.x' [ https://svn.apache.org/r1738576 ] QPID-7154: [Java Broker] Ensure that dead letter paths always locks the queue entry acquisition Merged with command: svn merge -c 1737804,1737984,1738119 ^/qpid/java/trunk > Dead lettering of a message may timeout at store level, causing unexpected > Broker shutdown > ------------------------------------------------------------------------------------------ > > Key: QPID-7154 > URL: https://issues.apache.org/jira/browse/QPID-7154 > Project: Qpid > Issue Type: Bug > Components: Java Broker > Affects Versions: 0.30, 0.32, qpid-java-6.0.1 > Reporter: Keith Wall > Fix For: qpid-java-6.0.2 > > Attachments: > 0001-QPID-7154-Java-Broker-Ensure-that-acquisition-is-loc.patch > > > The following was reported by a user using a 0.32 derivative. > The background was an operator was attempting to clear queue with very large > depth using JMX management {{QueueMBean#clearQueue}} as the same time as a > messaging client (consumer - connected to the same queue) was rejecting > messages which were being routed to another queue and then dequeued. > The message client (consumer) store level transaction timed out. This caused > the Broker to fail (uncaught exception). > {code} > com.sleepycat.je.LockTimeoutException: (JE 5.0.104) Lock expired. Locker > 792611890 1557851806_IoReceiver - /xxx.xx.xx.xx:32962_Txn: waited for lock on > database=QUEUE_ENTRIES LockAddr:1959781711 LSN=0x74a70/0x94db8e type=WRITE > grant=WAIT_NEW timeoutMillis=500 startTime=1458223769602 endTime=1458223770102 > Owners: [<LockInfo locker="1466269883 1557851804_RMI TCP > Connection(16333)-xx.xx.xx.xx_Txn" type="WRITE"/>] > Waiters: [] > > at > com.sleepycat.je.txn.LockManager.newLockTimeoutException(LockManager.java:665) > at > com.sleepycat.je.txn.LockManager.makeTimeoutMsgInternal(LockManager.java:623) > at > com.sleepycat.je.txn.SyncedLockManager.makeTimeoutMsg(SyncedLockManager.java:97) > at > com.sleepycat.je.txn.LockManager.lockInternal(LockManager.java:390) > at com.sleepycat.je.txn.LockManager.lock(LockManager.java:276) > at com.sleepycat.je.txn.Txn.lockInternal(Txn.java:522) > at com.sleepycat.je.txn.Locker.lock(Locker.java:443) > at > com.sleepycat.je.dbi.CursorImpl.lockLN(CursorImpl.java:2642) > at > com.sleepycat.je.dbi.CursorImpl.lockLN(CursorImpl.java:2443) > at > com.sleepycat.je.dbi.CursorImpl.searchAndPosition(CursorImpl.java:2168) > at com.sleepycat.je.Cursor.searchInternal(Cursor.java:2822) > at > com.sleepycat.je.Cursor.searchAllowPhantoms(Cursor.java:2732) > at com.sleepycat.je.Cursor.searchNoDups(Cursor.java:2586) > at com.sleepycat.je.Cursor.search(Cursor.java:2553) > at > com.sleepycat.je.Database.deleteInternal(Database.java:1151) > at com.sleepycat.je.Database.delete(Database.java:1080) > at > org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore.dequeueMessage(AbstractBDBMessageStore.java:819) > at > org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore.access$1000(AbstractBDBMessageStore.java:71) > at > org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore$BDBTransaction.dequeueMessage(AbstractBDBMessageStore.java:1496) > at > org.apache.qpid.server.txn.LocalTransaction.dequeue(LocalTransaction.java:110) > at > org.apache.qpid.server.queue.QueueEntryImpl.routeToAlternate(QueueEntryImpl.java:463) > at > org.apache.qpid.server.protocol.v0_8.AMQChannel.deadLetter(AMQChannel.java:1795) > at > org.apache.qpid.server.protocol.v0_8.AMQChannel.receiveBasicReject(AMQChannel.java:2431) > at > org.apache.qpid.framing.BasicRejectBody.process(BasicRejectBody.java:123) > at > org.apache.qpid.codec.ServerDecoder.processMethod(ServerDecoder.java:188) > at > org.apache.qpid.codec.AMQDecoder.processFrame(AMQDecoder.java:388) > at > org.apache.qpid.server.protocol.v0_8.BrokerDecoder.doProcessFrame(BrokerDecoder.java:113) > at > org.apache.qpid.server.protocol.v0_8.BrokerDecoder.access$000(BrokerDecoder.java:36) > at > org.apache.qpid.server.protocol.v0_8.BrokerDecoder$1.run(BrokerDecoder.java:79) > at > org.apache.qpid.server.protocol.v0_8.BrokerDecoder$1.run(BrokerDecoder.java:75) > at java.security.AccessController.doPrivileged(Native Method) > at javax.security.auth.Subject.doAs(Subject.java:415) > at > org.apache.qpid.server.protocol.v0_8.BrokerDecoder.processFrame(BrokerDecoder.java:74) > at > org.apache.qpid.codec.AMQDecoder.processInput(AMQDecoder.java:370) > at > org.apache.qpid.codec.AMQDecoder.decodeBuffer(AMQDecoder.java:259) > at > org.apache.qpid.server.protocol.v0_8.AMQProtocolEngine$2.run(AMQProtocolEngine.java:334) > at > org.apache.qpid.server.protocol.v0_8.AMQProtocolEngine$2.run(AMQProtocolEngine.java:311) > at java.security.AccessController.doPrivileged(Native Method) > at javax.security.auth.Subject.doAs(Subject.java:356) > at > org.apache.qpid.server.protocol.v0_8.AMQProtocolEngine.received(AMQProtocolEngine.java:310) > at > org.apache.qpid.server.protocol.v0_8.AMQProtocolEngine.received(AMQProtocolEngine.java:95) > at > org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:153) > at > org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:51) > at > org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:161) > at java.lang.Thread.run(Thread.java:744) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org