You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Lorenz Quack (JIRA)" <ji...@apache.org> on 2016/12/15 14:13:58 UTC
[jira] [Comment Edited] (QPID-7576) Metadata loaded twice for
recovered message
[ https://issues.apache.org/jira/browse/QPID-7576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751225#comment-15751225 ]
Lorenz Quack edited comment on QPID-7576 at 12/15/16 2:13 PM:
--------------------------------------------------------------
Here are some stacktraces (created in {{v0_8.MessageMetaData#MessageMetaData(MessagePublishInfo, ContentHeaderBody, long)}}, {{v0_8.MessageMetaData#dispose}}, and {{v0_8.MessageMetaData#clearEncodedForm}}:
On broker recovery:
{code}
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.<init>(MessageMetaData.java:66)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:172)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:150)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:45)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:29)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$JDBCMessageStoreReader.visitMessages(AbstractJDBCMessageStore.java:1761)
at org.apache.qpid.server.virtualhost.SynchronousMessageStoreRecoverer.recover(SynchronousMessageStoreRecoverer.java:78)
at org.apache.qpid.server.virtualhost.AbstractVirtualHost.postCreateDefaultExchangeTasks(AbstractVirtualHost.java:2526)
at org.apache.qpid.server.virtualhost.AbstractVirtualHost.onActivate(AbstractVirtualHost.java:2509)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.qpid.server.model.AbstractConfiguredObject.attainState(AbstractConfiguredObject.java:1549)
at org.apache.qpid.server.model.AbstractConfiguredObject.attainState(AbstractConfiguredObject.java:1528)
at org.apache.qpid.server.model.AbstractConfiguredObject$8.onSuccess(AbstractConfiguredObject.java:1102)
at org.apache.qpid.server.model.AbstractConfiguredObject$8.onSuccess(AbstractConfiguredObject.java:1096)
at org.apache.qpid.server.model.AbstractConfiguredObject$22$1.run(AbstractConfiguredObject.java:2676)
at org.apache.qpid.server.model.AbstractConfiguredObject$22$1.run(AbstractConfiguredObject.java:2672)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:356)
at org.apache.qpid.server.model.AbstractConfiguredObject$22.onSuccess(AbstractConfiguredObject.java:2671)
at com.google.common.util.concurrent.Futures$6.run(Futures.java:1319)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$ImmediateIfSameThreadExecutor.execute(TaskExecutorImpl.java:392)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl.execute(TaskExecutorImpl.java:175)
at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156)
at com.google.common.util.concurrent.ExecutionList.add(ExecutionList.java:101)
at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:170)
at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1322)
at org.apache.qpid.server.model.AbstractConfiguredObject.addFutureCallback(AbstractConfiguredObject.java:2666)
at org.apache.qpid.server.model.AbstractConfiguredObject.doAttainState(AbstractConfiguredObject.java:1095)
at org.apache.qpid.server.model.AbstractConfiguredObject.access$600(AbstractConfiguredObject.java:95)
at org.apache.qpid.server.model.AbstractConfiguredObject$1.execute(AbstractConfiguredObject.java:619)
at org.apache.qpid.server.model.AbstractConfiguredObject$1.execute(AbstractConfiguredObject.java:606)
at org.apache.qpid.server.model.AbstractConfiguredObject$2.execute(AbstractConfiguredObject.java:667)
at org.apache.qpid.server.model.AbstractConfiguredObject$2.execute(AbstractConfiguredObject.java:660)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$TaskLoggingWrapper.execute(TaskExecutorImpl.java:240)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$CallableWrapper$1.run(TaskExecutorImpl.java:312)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:356)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$CallableWrapper.call(TaskExecutorImpl.java:305)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
{code}
and on delivery of the message:
{code}
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.clearEncodedForm(MessageMetaData.java:146)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$MessageDataSoftRef.clear(AbstractJDBCMessageStore.java:1389)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$StoredJDBCMessage.flowToDisk(AbstractJDBCMessageStore.java:1658)
at org.apache.qpid.server.message.AbstractServerMessageImpl.getContent(AbstractServerMessageImpl.java:191)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl$MessageContentSourceBody.writePayload(ProtocolOutputConverterImpl.java:280)
at org.apache.qpid.framing.AMQFrame.writePayload(AMQFrame.java:69)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl$CompositeAMQBodyBlock.writePayload(ProtocolOutputConverterImpl.java:493)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.writeFrame(AMQPConnection_0_8Impl.java:378)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeFrame(ProtocolOutputConverterImpl.java:450)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeMessageDeliveryUnchanged(ProtocolOutputConverterImpl.java:234)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeMessageDelivery(ProtocolOutputConverterImpl.java:141)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeMessageDelivery(ProtocolOutputConverterImpl.java:98)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeDeliver(ProtocolOutputConverterImpl.java:82)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$WriteDeliverMethod.deliverToClient(AMQPConnection_0_8Impl.java:1239)
at org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8.sendToClient(ConsumerTarget_0_8.java:404)
at org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8$AckConsumer.doSend(ConsumerTarget_0_8.java:260)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.send(AbstractConsumerTarget.java:208)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.sendNextMessage(AbstractConsumerTarget.java:250)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.processPending(AbstractConsumerTarget.java:143)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.processPending(AMQChannel.java:3744)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$ProcessPendingIterator$3.run(AMQPConnection_0_8Impl.java:1448)
at org.apache.qpid.server.transport.NonBlockingConnection.processPending(NonBlockingConnection.java:356)
at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:264)
at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:126)
at org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:563)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:354)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:521)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.<init>(MessageMetaData.java:66)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:172)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:150)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:45)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:29)
at org.apache.qpid.server.store.AbstractJDBCMessageStore.getMetaData(AbstractJDBCMessageStore.java:991)
at org.apache.qpid.server.store.AbstractJDBCMessageStore.access$1200(AbstractJDBCMessageStore.java:56)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$StoredJDBCMessage.getMetaData(AbstractJDBCMessageStore.java:1455)
at org.apache.qpid.server.message.AbstractServerMessageImpl.isPersistent(AbstractServerMessageImpl.java:169)
at org.apache.qpid.server.queue.AbstractQueueEntryList.updateStatsOnStateChange(AbstractQueueEntryList.java:93)
at org.apache.qpid.server.queue.OrderedQueueEntryList.updateStatsOnStateChange(OrderedQueueEntryList.java:33)
at org.apache.qpid.server.queue.QueueEntryImpl.notifyStateChange(QueueEntryImpl.java:522)
at org.apache.qpid.server.queue.QueueEntryImpl.dispose(QueueEntryImpl.java:541)
at org.apache.qpid.server.queue.QueueEntryImpl.delete(QueueEntryImpl.java:558)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$MessageAcknowledgeAction.postCommit(AMQChannel.java:1576)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$AsyncCommand.complete(AMQChannel.java:1893)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.sync(AMQChannel.java:1836)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.receivedComplete(AMQChannel.java:354)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.receivedCompleteAllChannels(AMQPConnection_0_8Impl.java:282)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.access$100(AMQPConnection_0_8Impl.java:83)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:250)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:241)
at java.security.AccessController.doPrivileged(Native Method)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.received(AMQPConnection_0_8Impl.java:240)
at org.apache.qpid.server.transport.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:130)
at org.apache.qpid.server.transport.NonBlockingConnection.processAmqpData(NonBlockingConnection.java:593)
at org.apache.qpid.server.transport.NonBlockingConnectionPlainDelegate.processData(NonBlockingConnectionPlainDelegate.java:58)
at org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:483)
at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:270)
at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:126)
at org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:563)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:354)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:521)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.dispose(MessageMetaData.java:140)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$StoredJDBCMessage.remove(AbstractJDBCMessageStore.java:1636)
at org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference(AbstractServerMessageImpl.java:117)
at org.apache.qpid.server.message.AbstractServerMessageImpl.access$500(AbstractServerMessageImpl.java:37)
at org.apache.qpid.server.message.AbstractServerMessageImpl$Reference.release(AbstractServerMessageImpl.java:299)
at org.apache.qpid.server.queue.QueueEntryImpl.dispose(QueueEntryImpl.java:544)
at org.apache.qpid.server.queue.QueueEntryImpl.delete(QueueEntryImpl.java:558)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$MessageAcknowledgeAction.postCommit(AMQChannel.java:1576)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$AsyncCommand.complete(AMQChannel.java:1893)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.sync(AMQChannel.java:1836)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.receivedComplete(AMQChannel.java:354)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.receivedCompleteAllChannels(AMQPConnection_0_8Impl.java:282)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.access$100(AMQPConnection_0_8Impl.java:83)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:250)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:241)
at java.security.AccessController.doPrivileged(Native Method)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.received(AMQPConnection_0_8Impl.java:240)
at org.apache.qpid.server.transport.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:130)
at org.apache.qpid.server.transport.NonBlockingConnection.processAmqpData(NonBlockingConnection.java:593)
at org.apache.qpid.server.transport.NonBlockingConnectionPlainDelegate.processData(NonBlockingConnectionPlainDelegate.java:58)
at org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:483)
at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:270)
at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:126)
at org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:563)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:354)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:521)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
{code}
was (Author: lorenz.quack):
Here are some stacktraces (created in {{v0_8.MessageMetaData#MessageMetaData(MessagePublishInfo, ContentHeaderBody, long)}}, {{v0_8.MessageMetaData#dispose}}, and {{v0_8.MessageMetaData#clearEncodedForm}}:
On broker recovery:
{code}
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.<init>(MessageMetaData.java:66)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:172)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:150)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:45)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:29)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$JDBCMessageStoreReader.visitMessages(AbstractJDBCMessageStore.java:1761)
at org.apache.qpid.server.virtualhost.SynchronousMessageStoreRecoverer.recover(SynchronousMessageStoreRecoverer.java:78)
at org.apache.qpid.server.virtualhost.AbstractVirtualHost.postCreateDefaultExchangeTasks(AbstractVirtualHost.java:2526)
at org.apache.qpid.server.virtualhost.AbstractVirtualHost.onActivate(AbstractVirtualHost.java:2509)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.qpid.server.model.AbstractConfiguredObject.attainState(AbstractConfiguredObject.java:1549)
at org.apache.qpid.server.model.AbstractConfiguredObject.attainState(AbstractConfiguredObject.java:1528)
at org.apache.qpid.server.model.AbstractConfiguredObject$8.onSuccess(AbstractConfiguredObject.java:1102)
at org.apache.qpid.server.model.AbstractConfiguredObject$8.onSuccess(AbstractConfiguredObject.java:1096)
at org.apache.qpid.server.model.AbstractConfiguredObject$22$1.run(AbstractConfiguredObject.java:2676)
at org.apache.qpid.server.model.AbstractConfiguredObject$22$1.run(AbstractConfiguredObject.java:2672)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:356)
at org.apache.qpid.server.model.AbstractConfiguredObject$22.onSuccess(AbstractConfiguredObject.java:2671)
at com.google.common.util.concurrent.Futures$6.run(Futures.java:1319)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$ImmediateIfSameThreadExecutor.execute(TaskExecutorImpl.java:392)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl.execute(TaskExecutorImpl.java:175)
at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156)
at com.google.common.util.concurrent.ExecutionList.add(ExecutionList.java:101)
at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:170)
at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1322)
at org.apache.qpid.server.model.AbstractConfiguredObject.addFutureCallback(AbstractConfiguredObject.java:2666)
at org.apache.qpid.server.model.AbstractConfiguredObject.doAttainState(AbstractConfiguredObject.java:1095)
at org.apache.qpid.server.model.AbstractConfiguredObject.access$600(AbstractConfiguredObject.java:95)
at org.apache.qpid.server.model.AbstractConfiguredObject$1.execute(AbstractConfiguredObject.java:619)
at org.apache.qpid.server.model.AbstractConfiguredObject$1.execute(AbstractConfiguredObject.java:606)
at org.apache.qpid.server.model.AbstractConfiguredObject$2.execute(AbstractConfiguredObject.java:667)
at org.apache.qpid.server.model.AbstractConfiguredObject$2.execute(AbstractConfiguredObject.java:660)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$TaskLoggingWrapper.execute(TaskExecutorImpl.java:240)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$CallableWrapper$1.run(TaskExecutorImpl.java:312)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:356)
at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$CallableWrapper.call(TaskExecutorImpl.java:305)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
{code}
and on delivery of the message:
{code}
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.<init>(MessageMetaData.java:66)
at org.apache.qpid.server.protocol.v0_8.MessageConverter_Internal_to_v0_8.convertMetaData(MessageConverter_Internal_to_v0_8.java:157)
at org.apache.qpid.server.protocol.v0_8.MessageConverter_Internal_to_v0_8.convertToStoredMessage(MessageConverter_Internal_to_v0_8.java:80)
at org.apache.qpid.server.protocol.v0_8.MessageConverter_Internal_to_v0_8.convert(MessageConverter_Internal_to_v0_8.java:68)
at org.apache.qpid.server.protocol.v0_8.MessageConverter_Internal_to_v0_8.convert(MessageConverter_Internal_to_v0_8.java:49)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeDeliver(ProtocolOutputConverterImpl.java:78)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$WriteDeliverMethod.deliverToClient(AMQPConnection_0_8Impl.java:1239)
at org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8.sendToClient(ConsumerTarget_0_8.java:404)
at org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8$NoAckConsumer.doSend(ConsumerTarget_0_8.java:165)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.send(AbstractConsumerTarget.java:208)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.sendNextMessage(AbstractConsumerTarget.java:250)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.processPending(AbstractConsumerTarget.java:143)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.processPending(AMQChannel.java:3744)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$ProcessPendingIterator$3.run(AMQPConnection_0_8Impl.java:1448)
at org.apache.qpid.server.transport.NonBlockingConnection.processPending(NonBlockingConnection.java:356)
at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:264)
at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:126)
at org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:563)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:354)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:521)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.clearEncodedForm(MessageMetaData.java:146)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$MessageDataSoftRef.clear(AbstractJDBCMessageStore.java:1389)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$StoredJDBCMessage.flowToDisk(AbstractJDBCMessageStore.java:1658)
at org.apache.qpid.server.message.AbstractServerMessageImpl.getContent(AbstractServerMessageImpl.java:191)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl$MessageContentSourceBody.writePayload(ProtocolOutputConverterImpl.java:280)
at org.apache.qpid.framing.AMQFrame.writePayload(AMQFrame.java:69)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl$CompositeAMQBodyBlock.writePayload(ProtocolOutputConverterImpl.java:493)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.writeFrame(AMQPConnection_0_8Impl.java:378)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeFrame(ProtocolOutputConverterImpl.java:450)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeMessageDeliveryUnchanged(ProtocolOutputConverterImpl.java:234)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeMessageDelivery(ProtocolOutputConverterImpl.java:141)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeMessageDelivery(ProtocolOutputConverterImpl.java:98)
at org.apache.qpid.server.protocol.v0_8.ProtocolOutputConverterImpl.writeDeliver(ProtocolOutputConverterImpl.java:82)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$WriteDeliverMethod.deliverToClient(AMQPConnection_0_8Impl.java:1239)
at org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8.sendToClient(ConsumerTarget_0_8.java:404)
at org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8$AckConsumer.doSend(ConsumerTarget_0_8.java:260)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.send(AbstractConsumerTarget.java:208)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.sendNextMessage(AbstractConsumerTarget.java:250)
at org.apache.qpid.server.consumer.AbstractConsumerTarget.processPending(AbstractConsumerTarget.java:143)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.processPending(AMQChannel.java:3744)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$ProcessPendingIterator$3.run(AMQPConnection_0_8Impl.java:1448)
at org.apache.qpid.server.transport.NonBlockingConnection.processPending(NonBlockingConnection.java:356)
at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:264)
at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:126)
at org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:563)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:354)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:521)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.<init>(MessageMetaData.java:66)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:172)
at org.apache.qpid.server.protocol.v0_8.MessageMetaData$MetaDataFactory.createMetaData(MessageMetaData.java:150)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:45)
at org.apache.qpid.server.protocol.v0_8.MessageMetaDataType_0_8.createMetaData(MessageMetaDataType_0_8.java:29)
at org.apache.qpid.server.store.AbstractJDBCMessageStore.getMetaData(AbstractJDBCMessageStore.java:991)
at org.apache.qpid.server.store.AbstractJDBCMessageStore.access$1200(AbstractJDBCMessageStore.java:56)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$StoredJDBCMessage.getMetaData(AbstractJDBCMessageStore.java:1455)
at org.apache.qpid.server.message.AbstractServerMessageImpl.isPersistent(AbstractServerMessageImpl.java:169)
at org.apache.qpid.server.queue.AbstractQueueEntryList.updateStatsOnStateChange(AbstractQueueEntryList.java:93)
at org.apache.qpid.server.queue.OrderedQueueEntryList.updateStatsOnStateChange(OrderedQueueEntryList.java:33)
at org.apache.qpid.server.queue.QueueEntryImpl.notifyStateChange(QueueEntryImpl.java:522)
at org.apache.qpid.server.queue.QueueEntryImpl.dispose(QueueEntryImpl.java:541)
at org.apache.qpid.server.queue.QueueEntryImpl.delete(QueueEntryImpl.java:558)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$MessageAcknowledgeAction.postCommit(AMQChannel.java:1576)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$AsyncCommand.complete(AMQChannel.java:1893)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.sync(AMQChannel.java:1836)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.receivedComplete(AMQChannel.java:354)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.receivedCompleteAllChannels(AMQPConnection_0_8Impl.java:282)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.access$100(AMQPConnection_0_8Impl.java:83)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:250)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:241)
at java.security.AccessController.doPrivileged(Native Method)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.received(AMQPConnection_0_8Impl.java:240)
at org.apache.qpid.server.transport.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:130)
at org.apache.qpid.server.transport.NonBlockingConnection.processAmqpData(NonBlockingConnection.java:593)
at org.apache.qpid.server.transport.NonBlockingConnectionPlainDelegate.processData(NonBlockingConnectionPlainDelegate.java:58)
at org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:483)
at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:270)
at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:126)
at org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:563)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:354)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:521)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
java.lang.RuntimeException
at org.apache.qpid.server.protocol.v0_8.MessageMetaData.dispose(MessageMetaData.java:140)
at org.apache.qpid.server.store.AbstractJDBCMessageStore$StoredJDBCMessage.remove(AbstractJDBCMessageStore.java:1636)
at org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference(AbstractServerMessageImpl.java:117)
at org.apache.qpid.server.message.AbstractServerMessageImpl.access$500(AbstractServerMessageImpl.java:37)
at org.apache.qpid.server.message.AbstractServerMessageImpl$Reference.release(AbstractServerMessageImpl.java:299)
at org.apache.qpid.server.queue.QueueEntryImpl.dispose(QueueEntryImpl.java:544)
at org.apache.qpid.server.queue.QueueEntryImpl.delete(QueueEntryImpl.java:558)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$MessageAcknowledgeAction.postCommit(AMQChannel.java:1576)
at org.apache.qpid.server.protocol.v0_8.AMQChannel$AsyncCommand.complete(AMQChannel.java:1893)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.sync(AMQChannel.java:1836)
at org.apache.qpid.server.protocol.v0_8.AMQChannel.receivedComplete(AMQChannel.java:354)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.receivedCompleteAllChannels(AMQPConnection_0_8Impl.java:282)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.access$100(AMQPConnection_0_8Impl.java:83)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:250)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl$1.run(AMQPConnection_0_8Impl.java:241)
at java.security.AccessController.doPrivileged(Native Method)
at org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8Impl.received(AMQPConnection_0_8Impl.java:240)
at org.apache.qpid.server.transport.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:130)
at org.apache.qpid.server.transport.NonBlockingConnection.processAmqpData(NonBlockingConnection.java:593)
at org.apache.qpid.server.transport.NonBlockingConnectionPlainDelegate.processData(NonBlockingConnectionPlainDelegate.java:58)
at org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:483)
at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:270)
at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:126)
at org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:563)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:354)
at org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:521)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
{code}
> Metadata loaded twice for recovered message
> -------------------------------------------
>
> Key: QPID-7576
> URL: https://issues.apache.org/jira/browse/QPID-7576
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker
> Affects Versions: qpid-java-6.2
> Reporter: Keith Wall
> Fix For: qpid-java-6.1.1
>
>
> For recovered messages (and possibly messages that have been flown to disk), the metadata is evacuated from memory unnecessarily and then immediately reloaded.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org