Hello,
We are getting this exception resulting in resubmitting the messages again
to the queue. Can you please help how to resolve this?
Extract from QPid logs:
2019-10-29 03:07:23,757 INFO [IO-/10.72.88.6:39273] (q.m.c.close) -
[con:5,011(tis_fix@/10.72.88.6:39273/FIX_VHNG)/ch:2]
[con:5,011(tis_fix@/10.72.88.6:39273/FIX_VHNG)/ch:2] CHN-1003 : Close
2019-10-29 03:07:23,757 INFO [Broker-Config] (q.m.c.close) -
[con:5,009(tis_ctm@/10.72.88.6:39271/FIX_VHNG)] CON-1002 : Close :
Connection closed by external action
2019-10-29 03:07:23,757 INFO [IO-/10.65.106.158:53816] (q.m.c.close) -
[con:5,040(fis@/10.65.106.158:53816/FIX_VHNG)/ch:1]
[con:5,040(fis@/10.65.106.158:53816/FIX_VHNG)/ch:1] CHN-1003 : Close
2019-10-29 03:07:23,756 ERROR [IO-/10.72.88.6:35505]
(o.a.q.s.s.b.BDBConfigurationStore) - Unexpected BDB exception
org.apache.qpid.server.util.ConnectionScopedRuntimeException: Environment is
restarting
at
org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade.getEnvironment(ReplicatedEnvironmentFacade.java:1269)
at
org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade.beginTransaction(ReplicatedEnvironmentFacade.java:319)
at
org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore.removeMessage(AbstractBDBMessageStore.java:330)
at
org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore$StoredBDBMessage.remove(AbstractBDBMessageStore.java:1192)
at
org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference(AbstractServerMessageImpl.java:127)
at
org.apache.qpid.server.message.AbstractServerMessageImpl.access$500(AbstractServerMessageImpl.java:40)
at
org.apache.qpid.server.message.AbstractServerMessageImpl$Reference.release(AbstractServerMessageImpl.java:356)
at
org.apache.qpid.server.protocol.v1_0.StandardReceivingLinkEndpoint.receiveDelivery(StandardReceivingLinkEndpoint.java:364)
at
org.apache.qpid.server.protocol.v1_0.AbstractReceivingLinkEndpoint.receiveTransfer(AbstractReceivingLinkEndpoint.java:165)
at
org.apache.qpid.server.protocol.v1_0.Session_1_0.receiveTransfer(Session_1_0.java:614)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.receiveTransfer(AMQPConnection_1_0Impl.java:792)
at
org.apache.qpid.server.protocol.v1_0.type.transport.Transfer.invoke(Transfer.java:295)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.received(AMQPConnection_1_0Impl.java:515)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.lambda$receive$0(AMQPConnection_1_0Impl.java:467)
at java.security.AccessController.doPrivileged(Native Method)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.receive(AMQPConnection_1_0Impl.java:461)
at
org.apache.qpid.server.protocol.v1_0.framing.FrameHandler.parse(FrameHandler.java:224)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.onReceive(AMQPConnection_1_0Impl.java:1312)
at
org.apache.qpid.server.transport.AbstractAMQPConnection.lambda$received$2(AbstractAMQPConnection.java:574)
at java.security.AccessController.doPrivileged(Native Method)
at
org.apache.qpid.server.transport.AbstractAMQPConnection.received(AbstractAMQPConnection.java:569)
at
org.apache.qpid.server.transport.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:135)
at
org.apache.qpid.server.transport.NonBlockingConnection.processAmqpData(NonBlockingConnection.java:611)
at
org.apache.qpid.server.transport.NonBlockingConnectionPlainDelegate.processData(NonBlockingConnectionPlainDelegate.java:58)
at
org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:496)
at
org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:270)
at
org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:134)
at
org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:575)
at
org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:366)
at
org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at
org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:533)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at
org.apache.qpid.server.bytebuffer.QpidByteBufferFactory.lambda$null$0(QpidByteBufferFactory.java:464)
at java.lang.Thread.run(Thread.java:748)
2019-10-29 03:07:23,757 INFO [VirtualHostNode-RCO_1_FIX_VHN-Config]
(q.m.s.close) - [con:5,015(tis_fix@/10.72.88.6:39277/FIX_VHNG)/ch:1]
[sub:37(vh(/FIX_VHNG)/qu(QP.FTT.TIS.FIX.EXEC_RESP_5)] SUB-1002 : Close
2019-10-29 03:07:23,757 WARN [IO-/10.72.88.6:35505]
(o.a.q.s.p.v.f.FrameHandler) - Unexpected exception handling frame
org.apache.qpid.server.util.ConnectionScopedRuntimeException: Environment is
restarting
at
org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade.getEnvironment(ReplicatedEnvironmentFacade.java:1269)
at
org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade.beginTransaction(ReplicatedEnvironmentFacade.java:319)
at
org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore.removeMessage(AbstractBDBMessageStore.java:330)
at
org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore$StoredBDBMessage.remove(AbstractBDBMessageStore.java:1192)
at
org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference(AbstractServerMessageImpl.java:127)
at
org.apache.qpid.server.message.AbstractServerMessageImpl.access$500(AbstractServerMessageImpl.java:40)
at
org.apache.qpid.server.message.AbstractServerMessageImpl$Reference.release(AbstractServerMessageImpl.java:356)
at
org.apache.qpid.server.protocol.v1_0.StandardReceivingLinkEndpoint.receiveDelivery(StandardReceivingLinkEndpoint.java:364)
at
org.apache.qpid.server.protocol.v1_0.AbstractReceivingLinkEndpoint.receiveTransfer(AbstractReceivingLinkEndpoint.java:165)
at
org.apache.qpid.server.protocol.v1_0.Session_1_0.receiveTransfer(Session_1_0.java:614)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.receiveTransfer(AMQPConnection_1_0Impl.java:792)
at
org.apache.qpid.server.protocol.v1_0.type.transport.Transfer.invoke(Transfer.java:295)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.received(AMQPConnection_1_0Impl.java:515)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.lambda$receive$0(AMQPConnection_1_0Impl.java:467)
at java.security.AccessController.doPrivileged(Native Method)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.receive(AMQPConnection_1_0Impl.java:461)
at
org.apache.qpid.server.protocol.v1_0.framing.FrameHandler.parse(FrameHandler.java:224)
at
org.apache.qpid.server.protocol.v1_0.AMQPConnection_1_0Impl.onReceive(AMQPConnection_1_0Impl.java:1312)
at
org.apache.qpid.server.transport.AbstractAMQPConnection.lambda$received$2(AbstractAMQPConnection.java:574)
at java.security.AccessController.doPrivileged(Native Method)
at
org.apache.qpid.server.transport.AbstractAMQPConnection.received(AbstractAMQPConnection.java:569)
at
org.apache.qpid.server.transport.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:135)
at
org.apache.qpid.server.transport.NonBlockingConnection.processAmqpData(NonBlockingConnection.java:611)
at
org.apache.qpid.server.transport.NonBlockingConnectionPlainDelegate.processData(NonBlockingConnectionPlainDelegate.java:58)
at
org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:496)
at
org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:270)
at
org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:134)
at
org.apache.qpid.server.transport.SelectorThread$ConnectionProcessor.processConnection(SelectorThread.java:575)
at
org.apache.qpid.server.transport.SelectorThread$SelectionTask.performSelect(SelectorThread.java:366)
at
org.apache.qpid.server.transport.SelectorThread$SelectionTask.run(SelectorThread.java:97)
at
org.apache.qpid.server.transport.SelectorThread.run(SelectorThread.java:533)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at
org.apache.qpid.server.bytebuffer.QpidByteBufferFactory.lambda$null$0(QpidByteBufferFactory.java:464)
at java.lang.Thread.run(Thread.java:748)
2019-10-29 03:07:23,758 INFO [IO-/10.72.88.6:39277] (q.m.c.close) -
[con:5,015(tis_fix@/10.72.88.6:39277/FIX_VHNG)/ch:1]
[con:5,015(tis_fix@/10.72.88.6:39277/FIX_VHNG)/ch:1] CHN-1003 : Close
2019-10-29 03:07:23,758 INFO [IO-/10.72.88.6:39277] (q.m.c.close) -
[con:5,015(tis_fix@/10.72.88.6:39277/FIX_VHNG)/ch:2]
[con:5,015(tis_fix@/10.72.88.6:39277/FIX_VHNG)/ch:2] CHN-1003 : Close
2019-10-29 03:07:23,758 INFO [VirtualHostNode-RCO_1_FIX_VHN-Config]
(q.m.s.close) - [con:5,022(tis_fix@/10.72.88.6:39284/FIX_VHNG)/ch:2]
[sub:47(vh(/FIX_VHNG)/qu(QP.FTT.TIS.FIX.IOI_ADV)] SUB-1002 : Close
2019-10-29 03:07:23,758 INFO [IO-/10.65.106.158:53820] (q.m.c.close) -
[con:5,042(fis@/10.65.106.158:53820/FIX_VHNG)/ch:0]
[con:5,042(fis@/10.65.106.158:53820/FIX_VHNG)/ch:0] CHN-1003 : Close
2019-10-29 03:07:23,758 INFO [IO-/10.72.88.6:39284] (q.m.c.close) -
[con:5,022(tis_fix@/10.72.88.6:39284/FIX_VHNG)/ch:2]
[con:5,022(tis_fix@/10.72.88.6:39284/FIX_VHNG)/ch:2] CHN-1003 : Close
2019-10-29 03:07:23,758 INFO [IO-/10.65.106.158:53820] (q.m.c.close) -
[con:5,042(fis@/10.65.106.158:53820/FIX_VHNG)/ch:1]
[con:5,042(fis@/10.65.106.158:53820/FIX_VHNG)/ch:1] CHN-1003 : Close
--
Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
