You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Gordon Sim (JIRA)" <qp...@incubator.apache.org> on 2007/10/15 11:09:50 UTC
[jira] Commented: (QPID-628) Broker deletes durable queues on
connection closure.
[ https://issues.apache.org/jira/browse/QPID-628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_12534773 ]
Gordon Sim commented on QPID-628:
---------------------------------
The broker deletes exclusive queues when the connection ended, regardless of durability. In 0-10 the exclusive and auto-delete properties are entirely orthogonal, and the broker should be altered accordingly.
> 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
> Assignee: Gordon Sim
>
> asimon@redhat.com 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.