[ 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-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org