Broker deletes durable queues on connection closure.
----------------------------------------------------
Key: QPID-628
URL: https://issues.apache.org/jira/browse/QPID-628
Project: Qpid
Issue Type: Bug
Components: C++ Broker
Reporter: Alan Conway
[EMAIL PROTECTED] says:
I have attached a broker log. It shows that the broker tries to delete a
durable queue when the connection that was used to create it is closed.
This means that when we afterward try to query the broker about this
queue it always answers that this queue does not exist. I have the
feeling that this could well be an issue with the broker.
./qpidd -t
2007-Oct-09 18:37:31 info Persistence not enabled, no recovery attempted.
2007-Oct-09 18:37:31 info Listening on port 5672
2007-Oct-09 18:37:40 debug INIT [0x833ce10]
2007-Oct-09 18:37:40 debug SENT: Frame[channel=0; ConnectionStartBody:
version-major=0; version-minor=10; server-properties={}; mechanisms=PLAIN;
locales=en_US]
2007-Oct-09 18:37:40 debug RECV: Frame[channel=0; ConnectionStartOkBody:
client-properties={}; mechanism=PLAIN; response=guestguest; locale=utf8]
2007-Oct-09 18:37:40 debug SENT: Frame[channel=0; ConnectionTuneBody:
channel-max=32767; frame-max=65536; heartbeat=0]
2007-Oct-09 18:37:40 debug RECV: Frame[channel=0; ConnectionTuneOkBody:
channel-max=32767; frame-max=65536; heartbeat=0]
2007-Oct-09 18:37:40 debug RECV: Frame[channel=0; ConnectionOpenBody:
virtual-host=test; capabilities=; insist=1]
2007-Oct-09 18:37:40 debug SENT: Frame[channel=0; ConnectionOpenOkBody:
known-hosts=]
2007-Oct-09 18:37:40 debug INIT [0x837e0a0]
2007-Oct-09 18:37:40 debug SENT: Frame[channel=0; ConnectionStartBody:
version-major=0; version-minor=10; server-properties={}; mechanisms=PLAIN;
locales=en_US]
2007-Oct-09 18:37:40 debug RECV: Frame[channel=1; SessionOpenBody:
detached-lifetime=0]
2007-Oct-09 18:37:40 debug RECV: Frame[channel=1; ExchangeDeclareBody:
ticket=0; exchange=amq.topic; type=topic; alternate-exchange=; passive=0;
durable=0; auto-delete=0; arguments={}]
2007-Oct-09 18:37:40 debug SENT: Frame[channel=1; SessionAttachedBody:
session-id=abfb321b-9e9f-4d99-880c-a5be2505e235; detached-lifetime=0]
2007-Oct-09 18:37:41 debug RECV: Frame[channel=0; ConnectionStartOkBody:
client-properties={}; mechanism=PLAIN; response=guestguest; locale=utf8]
2007-Oct-09 18:37:41 debug SENT: Frame[channel=0; ConnectionTuneBody:
channel-max=32767; frame-max=65536; heartbeat=0]
2007-Oct-09 18:37:41 debug RECV: Frame[channel=0; ConnectionTuneOkBody:
channel-max=32767; frame-max=65536; heartbeat=0]
2007-Oct-09 18:37:41 debug RECV: Frame[channel=0; ConnectionOpenBody:
virtual-host=test; capabilities=; insist=1]
2007-Oct-09 18:37:41 debug SENT: Frame[channel=0; ConnectionOpenOkBody:
known-hosts=]
2007-Oct-09 18:37:41 debug RECV: Frame[channel=1; SessionOpenBody:
detached-lifetime=0]
2007-Oct-09 18:37:41 debug SENT: Frame[channel=1; SessionAttachedBody:
session-id=e3cffef4-47f6-463f-883a-1d98261d9af0; detached-lifetime=0]
2007-Oct-09 18:37:42 debug RECV: Frame[channel=1; BindingQueryBody: ticket=0;
exchange=amq.topic; queue=clientid:subscription0; routing-key=; arguments={}]
2007-Oct-09 18:37:42 debug SENT: Frame[channel=1; ExecutionResultBody:
command-id=0; data=�
]
2007-Oct-09 18:37:42 debug RECV: Frame[channel=1; ExchangeDeclareBody:
ticket=0; exchange=amq.topic; type=topic; alternate-exchange=; passive=0;
durable=0; auto-delete=0; arguments={}]
2007-Oct-09 18:37:42 debug RECV: Frame[channel=1; ExecutionSyncBody: ]
2007-Oct-09 18:37:42 debug SENT: Frame[channel=1; ExecutionCompleteBody:
cumulative-execution-mark=1; ranged-execution-set={}]
2007-Oct-09 18:37:42 debug RECV: Frame[channel=1; BindingQueryBody: ticket=0;
exchange=; queue=clientid:subscription0; routing-key=; arguments={}]
2007-Oct-09 18:37:42 debug SENT: Frame[channel=1; ExecutionResultBody:
command-id=2; data=�
]
2007-Oct-09 18:37:54 debug RECV: Frame[channel=1; QueueDeclareBody: ticket=0;
queue=clientid:subscription0; alternate-exchange=; passive=0; durable=1;
exclusive=1; auto-delete=0; arguments={}]
2007-Oct-09 18:37:54 info Can't create durable queue 'clientid:subscription0'.
Persistence not enabled.
2007-Oct-09 18:37:54 debug RECV: Frame[channel=1; ExecutionSyncBody: ]
2007-Oct-09 18:37:54 debug SENT: Frame[channel=1; ExecutionCompleteBody:
cumulative-execution-mark=3; ranged-execution-set={}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; BindingQueryBody: ticket=0;
exchange=amq.topic; queue=clientid:subscription0; routing-key=MyTopic3;
arguments={}]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; ExecutionResultBody:
command-id=4; data=�
]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; QueueBindBody: ticket=0;
queue=clientid:subscription0; exchange=amq.topic; routing-key=MyTopic3;
arguments={}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; ExecutionSyncBody: ]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; ExecutionCompleteBody:
cumulative-execution-mark=5; ranged-execution-set={}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; MessageSubscribeBody:
ticket=0; queue=clientid:subscription0; destination=1; no-local=0;
confirm-mode=1; acquire-mode=0; exclusive=0; filter={}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; MessageFlowModeBody:
destination=1; mode=1]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; ExecutionSyncBody: ]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; ExecutionCompleteBody:
cumulative-execution-mark=7; ranged-execution-set={}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; MessageFlowBody:
destination=1; unit=0; value=100]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; MessageFlowBody:
destination=1; unit=1; value=4294967295]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; ExecutionSyncBody: ]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; ExecutionCompleteBody:
cumulative-execution-mark=9; ranged-execution-set={}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; MessageTransferBody:
ticket=0; destination=amq.topic; confirm-mode=0; acquire-mode=0]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; header (133 bytes);
properties={DeliveryProperties: discard-unroutable=0; redelivered=0;
priority=0; delivery-mode=2; ttl=0; timestamp=1191947876587; expiration=0;
exchange=amq.topic; routing-key=MyTopic3MessageProperties: content-length=0;
message-id=ID:cca34fe3-3350-4530-a50d-60937e88f10a; correlation-id=;
reply-to=ReplyTo: exchange-name=; routing-key=; content-type=text/plain;
content-encoding=; type=; user-id=; app-id=; transaction-id=; security-token=;
application-headers={}}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; content (5 bytes) Hello...]
2007-Oct-09 18:37:56 info Can't enqueue message onto 'clientid:subscription0'.
Persistence not enabled.
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; MessageTransferBody:
ticket=0; destination=1; confirm-mode=1; acquire-mode=0]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; header (133 bytes);
properties={DeliveryProperties: discard-unroutable=0; redelivered=0;
priority=0; delivery-mode=2; ttl=0; timestamp=1191947876587; expiration=0;
exchange=amq.topic; routing-key=MyTopic3MessageProperties: content-length=0;
message-id=ID:cca34fe3-3350-4530-a50d-60937e88f10a; correlation-id=;
reply-to=ReplyTo: exchange-name=; routing-key=; content-type=text/plain;
content-encoding=; type=; user-id=; app-id=; transaction-id=; security-token=;
application-headers={}}]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; content (5 bytes) Hello...]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; MessageCancelBody:
destination=1]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; ExecutionSyncBody: ]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=1; ExecutionCompleteBody:
cumulative-execution-mark=10; ranged-execution-set={}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; SessionCloseBody: ]
2007-Oct-09 18:37:56 info Received session.close
2007-Oct-09 18:37:56 debug RECV: Frame[channel=0; ConnectionCloseBody:
reply-code=0; reply-text=client is closing; class-id=0; method-id=0]
2007-Oct-09 18:37:56 info Can't destroy durable queue 'clientid:subscription0'.
Persistence not enabled.
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; MessageTransferBody:
ticket=0; destination=amq.topic; confirm-mode=0; acquire-mode=0]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; header (133 bytes);
properties={DeliveryProperties: discard-unroutable=0; redelivered=0;
priority=0; delivery-mode=2; ttl=0; timestamp=1191947876722; expiration=0;
exchange=amq.topic; routing-key=MyTopic3MessageProperties: content-length=0;
message-id=ID:cf6ac83b-363c-403c-9691-5b80e8abd334; correlation-id=;
reply-to=ReplyTo: exchange-name=; routing-key=; content-type=text/plain;
content-encoding=; type=; user-id=; app-id=; transaction-id=; security-token=;
application-headers={}}]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=1; content (6 bytes) Hello2...]
2007-Oct-09 18:37:56 debug INIT [0x837e568]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=0; ConnectionStartBody:
version-major=0; version-minor=10; server-properties={}; mechanisms=PLAIN;
locales=en_US]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=0; ConnectionStartOkBody:
client-properties={}; mechanism=PLAIN; response=guestguest; locale=utf8]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=0; ConnectionTuneBody:
channel-max=32767; frame-max=65536; heartbeat=0]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=0; ConnectionTuneOkBody:
channel-max=32767; frame-max=65536; heartbeat=0]
2007-Oct-09 18:37:56 debug RECV: Frame[channel=0; ConnectionOpenBody:
virtual-host=test; capabilities=; insist=1]
2007-Oct-09 18:37:56 debug SENT: Frame[channel=0; ConnectionOpenOkBody:
known-hosts=]
q
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
