Re: [c++]: Progressing AMQP 1.0 support for 0.22 release

Bruno Matos Tue, 14 May 2013 06:04:34 -0700

On Ter, 2013-05-14 at 11:49 +0100, Gordon Sim wrote:
> On 05/14/2013 11:40 AM, Bruno Matos wrote:


> >> Is that the case even when you have NONE selected for the
> >> sasl_mechanisms in the link? There does seem to be an issue with
> >> interbroker SASL which I am investigating.
> >>
> >
> > Yes.
> > I'm trying to do some debugging myself, not that I have the knowledge,
> > but if I find something 'strange' I'll let you know.
> 
> You can turn on some protocol logging with --log-enable trace:Protocol 
> (note however that the actual output comes from the proton lib and that 
> doesn't yet honour any output to file or syslog options (i.e. it just 
> goes to the console).
> 
> If you want to send me the output I can also take a look.
> 

I send the output from the se source broker in attachment, the output of
the destination broker was only
    <- AMQP
    -> AMQP

I don't understand the use of NONE vs ANONYMOUS, sometimes they seam
exchangeable... I saw ANONYMOUS in the Domain initialization of
mechanisms internal variable either.

2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: INIT(0-10)
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionStartBody: server-properties={qpid.federation_tag:V2:36:str16(5830e094-a80a-4bf2-b499-136d492bee4d)}; mechanisms=str16{V2:9:str16(ANONYMOUS), V2:5:str16(PLAIN)}; locales=str16{V2:5:str16(en_US)}; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionStartOkBody: client-properties={platform:V2:5:str16(posix),product:V2:18:str16(qpid python client),qpid.client_pid:F8:int64(23149),qpid.client_ppid:F8:int64(9356),qpid.client_process:V2:9:str16(qpid-ctrl),version:V2:11:str16(development)}; mechanism=ANONYMOUS; response=xxxxxx; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionTuneBody: channel-max=32767; max-frame-size=65535; heartbeat-min=0; heartbeat-max=120; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionTuneOkBody: channel-max=32767; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionOpenBody: }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionOpenOkBody: known-hosts=str16{}; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionAttachBody: name=d7320341-c93a-4c61-90e8-3c672f17c499:0; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCommandPointBody: command-id=0; command-offset=0; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ExchangeQueryBody: name=qmf.default.direct; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {QueueQueryBody: queue=qmf.default.direct; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionAttachedBody: name=d7320341-c93a-4c61-90e8-3c672f17c499:0; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCommandPointBody: command-id=0; command-offset=0; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ExecutionResultBody: command-id=0; value=\x07\x01	\x00\x11management-direct\x00\x00\x00\x1A\x00\x00\x00\x01\x0Eqpid.replicate\x95\x00\x04none; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,0] }; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ExecutionResultBody: command-id=1; value=\x08\x01\x00\x00; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,1] }; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {QueueDeclareBody: queue=d7320341-c93a-4c61-90e8-3c672f17c499:0.0; exclusive=1; auto-delete=1; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ExchangeBindBody: queue=d7320341-c93a-4c61-90e8-3c672f17c499:0.0; exchange=qmf.default.direct; binding-key=c0f1c7ec-dc71-47bd-9af3-6f889cc72a43; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {MessageSubscribeBody: queue=d7320341-c93a-4c61-90e8-3c672f17c499:0.0; destination=0; accept-mode=1; acquire-mode=0; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {MessageSetFlowModeBody: destination=0; flow-mode=0; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,5] }; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[Bbe; channel=0; {MessageTransferBody: destination=qmf.default.direct; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[be; channel=0; header (183 bytes); properties={{MessageProperties: reply-to={ReplyTo: exchange=qmf.default.direct; routing-key=c0f1c7ec-dc71-47bd-9af3-6f889cc72a43; }; content-type=amqp/map; app-id=qmf2; application-headers={qmf.opcode:V2:15:str16(_method_request),qpid.subject:V2:6:str16(broker),x-amqp-0-10.app-id:V2:4:str16(qmf2)}; }{DeliveryProperties: routing-key=broker; }}]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[Ebe; channel=0; content (205 bytes) \x00\x00\x00\xC9\x00\x00\x00\x03
_object_id\xA8\x00\x00\x00=\x00\x00\x00\x01_ob...]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,6] }; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {MessageFlowBody: destination=0; unit=1; value=4294967295; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {MessageFlowBody: destination=0; unit=0; value=1; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[Bbe; channel=0; {MessageTransferBody: destination=0; accept-mode=1; acquire-mode=0; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[be; channel=0; header (151 bytes); properties={{MessageProperties: content-length=28; content-type=amqp/map; app-id=qmf2; application-headers={method:V2:8:str16(response),qmf.agent:V2:6:str16(broker),qmf.opcode:V2:16:str16(_method_response)}; }{DeliveryProperties: routing-key=c0f1c7ec-dc71-47bd-9af3-6f889cc72a43; }}]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[Ebe; channel=0; content (28 bytes) \x00\x00\x00\x18\x00\x00\x00\x01
_arguments\xA8\x00\x00\x00\x04\x00\x00\x00\x00]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ExecutionSyncBody: }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,9] }; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {MessageCancelBody: destination=0; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {QueueDeleteBody: queue=d7320341-c93a-4c61-90e8-3c672f17c499:0.0; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,11] }; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionDetachBody: name=d7320341-c93a-4c61-90e8-3c672f17c499:0; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {SessionDetachedBody: name=d7320341-c93a-4c61-90e8-3c672f17c499:0; code=0; }]
2013-05-14 13:52:58 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionCloseBody: reply-code=200; }]
2013-05-14 13:52:58 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36800]: Frame[BEbe; channel=0; {ConnectionCloseOkBody: }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: INIT(0-10)
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionStartBody: server-properties={qpid.federation_tag:V2:36:str16(5830e094-a80a-4bf2-b499-136d492bee4d)}; mechanisms=str16{V2:9:str16(ANONYMOUS), V2:5:str16(PLAIN)}; locales=str16{V2:5:str16(en_US)}; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionStartOkBody: client-properties={platform:V2:5:str16(posix),product:V2:18:str16(qpid python client),qpid.client_pid:F8:int64(23155),qpid.client_ppid:F8:int64(9356),qpid.client_process:V2:9:str16(qpid-ctrl),version:V2:11:str16(development)}; mechanism=ANONYMOUS; response=xxxxxx; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionTuneBody: channel-max=32767; max-frame-size=65535; heartbeat-min=0; heartbeat-max=120; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionTuneOkBody: channel-max=32767; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionOpenBody: }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionOpenOkBody: known-hosts=str16{}; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionAttachBody: name=66aa95a6-a056-4c42-9eae-b35323a279bf:0; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCommandPointBody: command-id=0; command-offset=0; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ExchangeQueryBody: name=qmf.default.direct; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {QueueQueryBody: queue=qmf.default.direct; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionAttachedBody: name=66aa95a6-a056-4c42-9eae-b35323a279bf:0; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCommandPointBody: command-id=0; command-offset=0; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ExecutionResultBody: command-id=0; value=\x07\x01	\x00\x11management-direct\x00\x00\x00\x1A\x00\x00\x00\x01\x0Eqpid.replicate\x95\x00\x04none; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,0] }; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ExecutionResultBody: command-id=1; value=\x08\x01\x00\x00; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,1] }; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {QueueDeclareBody: queue=66aa95a6-a056-4c42-9eae-b35323a279bf:0.0; exclusive=1; auto-delete=1; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ExchangeBindBody: queue=66aa95a6-a056-4c42-9eae-b35323a279bf:0.0; exchange=qmf.default.direct; binding-key=8cf6d9f1-9f40-446e-8e22-64f71a5b500f; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {MessageSubscribeBody: queue=66aa95a6-a056-4c42-9eae-b35323a279bf:0.0; destination=0; accept-mode=1; acquire-mode=0; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {MessageSetFlowModeBody: destination=0; flow-mode=0; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,5] }; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[Bbe; channel=0; {MessageTransferBody: destination=qmf.default.direct; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[be; channel=0; header (183 bytes); properties={{MessageProperties: reply-to={ReplyTo: exchange=qmf.default.direct; routing-key=8cf6d9f1-9f40-446e-8e22-64f71a5b500f; }; content-type=amqp/map; app-id=qmf2; application-headers={qmf.opcode:V2:15:str16(_method_request),qpid.subject:V2:6:str16(broker),x-amqp-0-10.app-id:V2:4:str16(qmf2)}; }{DeliveryProperties: routing-key=broker; }}]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[Ebe; channel=0; content (244 bytes) \x00\x00\x00\xF0\x00\x00\x00\x03
_object_id\xA8\x00\x00\x00=\x00\x00\x00\x01_ob...]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,6] }; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {MessageFlowBody: destination=0; unit=1; value=4294967295; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {MessageFlowBody: destination=0; unit=0; value=1; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[Bbe; channel=0; {MessageTransferBody: destination=0; accept-mode=1; acquire-mode=0; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[be; channel=0; header (151 bytes); properties={{MessageProperties: content-length=28; content-type=amqp/map; app-id=qmf2; application-headers={method:V2:8:str16(response),qmf.agent:V2:6:str16(broker),qmf.opcode:V2:16:str16(_method_response)}; }{DeliveryProperties: routing-key=8cf6d9f1-9f40-446e-8e22-64f71a5b500f; }}]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[Ebe; channel=0; content (28 bytes) \x00\x00\x00\x18\x00\x00\x00\x01
_arguments\xA8\x00\x00\x00\x04\x00\x00\x00\x00]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ExecutionSyncBody: }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,9] }; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {MessageCancelBody: destination=0; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {QueueDeleteBody: queue=66aa95a6-a056-4c42-9eae-b35323a279bf:0.0; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionCompletedBody: commands={ [0,11] }; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionDetachBody: name=66aa95a6-a056-4c42-9eae-b35323a279bf:0; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {SessionDetachedBody: name=66aa95a6-a056-4c42-9eae-b35323a279bf:0; code=0; }]
2013-05-14 13:53:00 [Protocol] trace RECV [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionCloseBody: reply-code=200; }]
2013-05-14 13:53:00 [Protocol] trace SENT [qpid.127.0.0.1:5672-127.0.0.1:36801]: Frame[BEbe; channel=0; {ConnectionCloseOkBody: }]

---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org
For additional commands, e-mail: users-h...@qpid.apache.org

Re: [c++]: Progressing AMQP 1.0 support for 0.22 release

Reply via email to