AMQP1.0 - QPID Proton python sending message to RabbitMQ 3.13.1 Queue. #11148

sylvainrichardcool · 2024-05-02T09:12:55Z

sylvainrichardcool
May 2, 2024

Hi all,
I try to send message with a AMQP1.0 QPID Proton python sender in a RabbitMQ Queue.

I want to use the plugin rabbitmq_amqp1_0

[E*] rabbitmq_amqp1_0                  3.13.1

The QPID Proton python receiver works well. I can consume message from a Queue in RabbitMQ.

On the sender side I have some error on the rabbitMQ logs.
Please explain me the issue.

trace: python client

   -I- trying connection amqp://myhost.com:5676/exampleQueuend
   -I-   url=amqp://myhost.com:5676
   -I-   address=/amq/queue/exampleQueuend
<proton._endpoints.Connection 0x7f6aa34e8da0 ~ 0x55d50f0fb4a0>
   -I- Sender sender1 is created
   -I-  Max msg size (0 is unlimited)=  0
[0x55d50ef68c50]: SASL:FRAME:  -> SASL
[0x55d50ef68c50]: SASL:FRAME:  <- SASL
[0x55d50ef68c50]: AMQP:FRAME:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@<symbol>[:ANONYMOUS, :PLAIN, :AMQPLAIN]]
[0x55d50ef68c50]: AMQP:FRAME:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\x00test\x00test"]
[0x55d50ef68c50]: AMQP:FRAME:0 <- @sasl-outcome(68) [code=0x0]
[0x55d50ef68c50]: AMQP:FRAME:  -> AMQP
[0x55d50ef68c50]: AMQP:FRAME:0 -> @open(16) [container-id="Client Python QIP send - sylvain", hostname="myhost.com", channel-max=0x7fff]
[0x55d50ef68c50]: AMQP:FRAME:0 -> @begin(17) [next-outgoing-id=0x0, incoming-window=0x7fffffff, outgoing-window=0x7fffffff]
[0x55d50ef68c50]: AMQP:FRAME:0 -> @attach(18) [name="sender1", handle=0x0, role=false, snd-settle-mode=0x2, rcv-settle-mode=0x0, source=@source(40) [durable=0x0, timeout=0x0, dynamic=false], target=@target(41) [address="/amq/queue/exampleQueuend", durable=0x0, timeout=0x0, dynamic=false, capabilities=:queue], initial-delivery-count=0x0, max-message-size=0x0]
[0x55d50ef68c50]: AMQP:FRAME:  <- AMQP
[0x55d50ef68c50]: AMQP:FRAME:0 <- @open(16) [container-id="rabbit@tdubxasga-br01", channel-max=0x7fff, idle-time-out=0xea60, properties={:"cluster_name"="rabbit@tdubxasga-br01", :copyright="Copyright (c) 2007-2024 Broadcom Inc and/or its subsidiaries", :information="Licensed under the MPL 2.0. Website: https://rabbitmq.com", :platform="Erlang/OTP 26.2.4", :product="RabbitMQ", :version="3.13.1"}]
[0x55d50ef68c50]: AMQP:FRAME:0 <- @begin(17) [remote-channel=0x0, next-outgoing-id=0x0, incoming-window=0xffff, outgoing-window=0xffff, handle-max=0xffffffff]
[0x55d50ef68c50]: AMQP:FRAME:0 <- @attach(18) [name="sender1", handle=0x0, role=true, snd-settle-mode=0x2, rcv-settle-mode=0x0, source=@source(40) [durable=0x0, timeout=0x0, dynamic=false], target=@target(41) [address="/amq/queue/exampleQueuend", durable=0x0, timeout=0x0, dynamic=false, capabilities=:queue]]
[0x55d50ef68c50]: AMQP:FRAME:0 <- @flow(19) [next-incoming-id=0x0, incoming-window=0xffff, next-outgoing-id=0x0, outgoing-window=0xffff, handle=0x0, link-credit=0x10000, drain=false, echo=false]
   -I- Connection <proton._endpoints.Connection 0x7f6aa34e8d68 ~ 0x55d50f0fb4a0> is open
   -I- connection use url amqp://myhost.com:5676
   -I- SEND: sender link opened <proton._endpoints.Sender 0x7f6aa34e8fd0 ~ 0x55d50ef549b0>  for target address '/amq/queue/exampleQueuend'
   -I- Credits= 65536
Send msg id=1    Delivery<proton._delivery.Delivery 0x7f6aa34e8e80 ~ 0x55d50f115360>
[0x55d50ef68c50]: AMQP:FRAME:0 -> @transfer(20) [handle=0x0, delivery-id=0x0, delivery-tag=b"1", message-format=0x0] (131) \x00Sp\xc0\x02\x01A\x00Ss\xc0@\x0aS\x01\xa0\x0dbatch-sylvain@\xa1\x0ctest message@@\xa3\x10application/json@@\x83\x00\x00\x01\x8f8\x84\xb3\xe0\x00St\xd1\x00\x00\x00\x17\x00\x00\x00\x02\xa1\x08producer\xa1\x07sender1\x00Sw\xd1\x00\x00\x00\x10\x00\x00\x00\x02\xa1\x08sequenceU\x01
   -I- Credits= 65535
[0x55d50ef68c50]: AMQP:FRAME:0 <- @end(23) [error=@error(29) [condition=:"amqp:internal-error", description="{badarg,[{erlang,size,[1],[{error_info,#{module => erl_erts_errors}}]},{rabbit_framing_amqp_0_9_1,encode_properties,1,[{file,[114,97,98,98,105,116,95,102,114,97,109,105,110,103,95,97,109,113,112,95,48,95,57,95,49,46,101,114,108]},{line,1202}]},{rabbit_binary_generator,ensure_content_encoded,2,[{file,[114,97,98,98,105,116,95,98,105,110,97,114,121,95,103,101,110,101,114,97,116,111,114,46,101,114,108]},{line,184}]},{mc_amqpl,prepare,2,[{file,[109,99,95,97,109,113,112,108,46,101,114,108]},{line,268}]},{mc,prepare,2,[{file,[109,99,46,101,114,108]},{line,428}]},{rabbit_classic_queue,deliver,3,[{file,[114,97,98,98,105,116,95,99,108,97,115,115,105,99,95,113,117,101,117,101,46,101,114,108]},{line,372}]},{rabbit_queue_type,\x27-deliver0/4-fun-5-\x27,5,[{file,[114,97,98,98,105,116,95,113,117,101,117,101,95,116,121,112,101,46,101,114,108]},{line,586}]},{maps,fold_1,4,[{file,[109,97,112,115,46,101,114,108]},{line,416}]}]}"]]
   -E- Session closed with error
[0x55d50ef68c50]: AMQP:FRAME:0 -> @end(23) []

trace: RabbitMQ log

2024-05-02 08:55:29.151640+00:00 [info] <0.20841.0> accepting AMQP connection <0.20841.0> (172.1.1.41:46434 -> 172.1.1.41:5676)
2024-05-02 08:55:29.155282+00:00 [info] <0.20841.0> AMQP 1.0 connection <0.20841.0>: user 'test' authenticated
2024-05-02 08:55:29.161499+00:00 [info] <0.20841.0> AMQP 1.0 connection <0.20841.0>: user 'test' authenticated and granted access to vhost '/'
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0> ** Generic server <0.20862.0> terminating
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0> ** Last message in was {'$gen_cast',
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            {method,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                {'basic.publish',0,<<>>,<<"exampleQueue">>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                    true,false},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                {content,60,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                    {'P_basic',<<"application/json">>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                        undefined,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                        [{<<"x-amqp-1.0-app-properties">>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                          longstr,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                          <<0,83,116,209,0,0,0,23,0,0,0,2,161,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            8,112,114,111,100,117,99,101,114,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            161,7,115,101,110,100,101,114,49>>},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                         {<<"x-amqp-1.0-properties">>,longstr,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                          <<0,83,115,192,64,10,83,1,160,13,98,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            97,116,99,104,45,115,121,108,118,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            97,105,110,64,161,12,116,101,115,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            116,32,109,101,115,115,97,103,101,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            64,64,163,16,97,112,112,108,105,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            99,97,116,105,111,110,47,106,115,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            111,110,64,64,131,0,0,1,143,56,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                            132,11,232>>}],
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                        2,undefined,undefined,undefined,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                        undefined,1,1714640129000,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                        <<"amqp-1.0">>,<<"batch-sylvain">>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                        undefined,undefined},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                    none,none,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                    [<<0,83,119,209,0,0,0,16,0,0,0,2,161,8,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                       115,101,113,117,101,110,99,101,85,1>>]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                                flow}}
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0> ** When Server state == {ch,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          {conf,running,rabbit_framing_amqp_0_9_1,1,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           <0.20858.0>,<0.20858.0>,<0.20850.0>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           <<"172.1.1.41:46434 -> 172.1.1.41:5676 (0)">>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           undefined,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           {user,<<"test">>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            [impersonator],
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            [{rabbit_auth_backend_internal,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                              #Fun<rabbit_auth_backend_internal.3.111050101>}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           <<"/">>,<<>>,<0.20855.0>,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           [{<<"publisher_confirms">>,bool,true},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            {<<"exchange_exchange_bindings">>,bool,true},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            {<<"basic.nack">>,bool,true},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            {<<"consumer_cancel_notify">>,bool,true},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            {<<"connection.blocked">>,bool,true},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                            {<<"authentication_failure_close">>,bool,true}],
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           none,65535,134217728,1800000,#{},infinity,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           1000000000,true},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          {lstate,<0.20861.0>,false},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          none,1,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          {0,[],[]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          {state,#{},erlang},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          #{},#{},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          {state,fine,5000,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                           #Ref<0.1774606182.1419509762.176095>},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          true,1,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          {rabbit_confirms,undefined,#{}},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          [],[],none,flow,[],
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          {rabbit_queue_type,#{}},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>                          #Ref<0.1774606182.1419509762.176090>,false}
**2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0> ** Reason for termination ==**
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0> ** {badarg,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>        [{erlang,size,[1],[{error_info,#{module => erl_erts_errors}}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>         {rabbit_framing_amqp_0_9_1,encode_properties,1,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>             [{file,"rabbit_framing_amqp_0_9_1.erl"},{line,1202}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>         {rabbit_binary_generator,ensure_content_encoded,2,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>             [{file,"rabbit_binary_generator.erl"},{line,184}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>         {mc_amqpl,prepare,2,[{file,"mc_amqpl.erl"},{line,268}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>         {mc,prepare,2,[{file,"mc.erl"},{line,428}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>         {rabbit_classic_queue,deliver,3,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>             [{file,"rabbit_classic_queue.erl"},{line,372}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>         {rabbit_queue_type,'-deliver0/4-fun-5-',5,
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>             [{file,"rabbit_queue_type.erl"},{line,586}]},
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>         {maps,fold_1,4,[{file,"maps.erl"},{line,416}]}]}
2024-05-02 08:55:29.170479+00:00 [error] <0.20862.0>
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>   crasher:
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     initial call: rabbit_channel:init/1
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     pid: <0.20862.0>
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     registered_name: []
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     exception exit: {badarg,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                         [{erlang,size,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                              [1],
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                              [{error_info,#{module => erl_erts_errors}}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          {rabbit_framing_amqp_0_9_1,encode_properties,1,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                              [{file,"rabbit_framing_amqp_0_9_1.erl"},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                               {line,1202}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          {rabbit_binary_generator,ensure_content_encoded,2,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                              [{file,"rabbit_binary_generator.erl"},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                               {line,184}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          {mc_amqpl,prepare,2,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                              [{file,"mc_amqpl.erl"},{line,268}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          {mc,prepare,2,[{file,"mc.erl"},{line,428}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          {rabbit_classic_queue,deliver,3,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                              [{file,"rabbit_classic_queue.erl"},{line,372}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          {rabbit_queue_type,'-deliver0/4-fun-5-',5,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                              [{file,"rabbit_queue_type.erl"},{line,586}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          {maps,fold_1,4,[{file,"maps.erl"},{line,416}]}]}
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       in function  gen_server2:terminate/3 (gen_server2.erl, line 1172)
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     ancestors: [<0.20860.0>,rabbit_direct_client_sup,rabbit_sup,<0.249.0>]
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     message_queue_len: 0
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     messages: []
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     links: [<0.20860.0>,<0.20858.0>]
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     dictionary: [{credit_flow_default_credit,{400,200}},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {rand_seed,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                       {#{max => 288230376151711743,type => exsplus,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          next => #Fun<rand.5.65977474>,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                          jump => #Fun<rand.3.65977474>},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                        [196595684637794947|235789394916761965]}},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {channel_operation_timeout,15000},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {msg_size_for_gc,24},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {process_name,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                       {rabbit_channel,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                           {<<"172.1.1.41:46434 -> 172.1.1.41:5676 (0)">>,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                            1}}},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {permission_cache_can_expire,false},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {guid,{{1409876544,368776586,359998392,2651766829},0}},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {permission_cache,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                       [{{resource,<<"/">>,exchange,<<>>},#{},write}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {{credit_to,<0.20858.0>},199}]
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     trap_exit: true
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     status: running
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     heap_size: 10958
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     stack_size: 28
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     reductions: 56589
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>   neighbours:
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>     neighbour:
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       pid: <0.20858.0>
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       registered_name: []
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       initial call: amqp_channel:init/1
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       current_function: {gen_server,loop,7}
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       ancestors: [<0.20856.0>,<0.20853.0>,<0.20849.0>,<0.20848.0>,amqp_sup,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   <0.506.0>]
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       message_queue_len: 0
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       links: [<0.20856.0>,<0.20862.0>]
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       trap_exit: false
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       status: waiting
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       heap_size: 376
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       stack_size: 11
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       reductions: 449
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>       current_stacktrace: [{gen_server,loop,7,[{file,"gen_server.erl"},{line,1001}]},
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                   {proc_lib,init_p_do_apply,3,
2024-05-02 08:55:29.171468+00:00 [error] <0.20862.0>                             [{file,"proc_lib.erl"},{line,241}]}]
2024-05-02 08:55:29.172614+00:00 [warning] <0.20847.0> Closing session for connection <0.20841.0>:
...

I already tried with these prefixes, I have the same problem. https://github.com/rabbitmq/rabbitmq-amqp1.0?tab=readme-ov-file#routing-and-addressing

| "/amq/queue/" Q         Publish to default exchange with routing key Q
| "/queue/"     Q         Publish to default exchange with routing key Q
| Q (no leading slash)    Publish to default exchange with routing key Q

More detail.
For sender and receiver I use the "test" user.

rabbitmqctl list_users
Listing users ...
user    tags
admin   [administrator]
test    [impersonator]
guest   [administrator]

rabbitmqctl list_user_permissions test
Listing permissions for user "test" ...
vhost   configure       write   read
/       .*      .*      .*

rabbitmqctl list_exchanges
Listing exchanges for vhost / ...
name    type
amq.topic       topic
amq.fanout      fanout
amq.rabbitmq.trace      topic
amq.match       headers
amq.direct      direct
amq.headers     headers
        direct

I use the "AMQP default" exchange.

I create 2 queues for testing.

Sylvain

Answered by lukebakken

May 7, 2024

cc @sylvainrichardcool

Thanks @kjnilsson, indeed, if you change the code to this:

lukebakken/rabbitmq-server-11148-11151@5b9be59

...it works.

Though, the QPID proton docs state that an integer should work:

https://qpid.apache.org/releases/qpid-proton-0.39.0/proton/python/docs/proton.html#proton.Message.id

View full answer

lukebakken · 2024-05-02T14:26:32Z

lukebakken
May 2, 2024
Maintainer

Please see this comment in your other discussion. We need more information when you report issues.

Also, please make a note of how I used <details> and <summary> to make your issues easier to read. You can always upload files that contain large amounts of text as well. Just pasting it makes issues very difficult to read.

0 replies

sylvainrichardcool · 2024-05-02T18:05:18Z

sylvainrichardcool
May 2, 2024
Author

Hi luke
thank you.

please find the information in the attachment file.
sender.txt

You can clone from https://github.com/sylvainrichardcool/amqp1.0-qpid-proton-python

You can reproduce the issue in each queue.

PN_TRACE_FRM=1 python3 sender-amqp_rabbitmq.py --address amqp://myhost.com:5676/exampleQueue -m 1 #durable queue
PN_TRACE_FRM=1 python3 sender-amqp_rabbitmq.py --address amqp://myhost.com:5676/exampleQueuend -m 1 #not durable queue
PN_TRACE_FRM=1 python3 sender-amqp_rabbitmq.py --address amqp://myhost.com:5676/exampleQueueStream -m 1 #durable stream

Sylvain

0 replies

lukebakken · 2024-05-06T18:13:46Z

lukebakken
May 6, 2024
Maintainer

@sylvainrichardcool thank you for providing your code. I forked your repository here and made everything a bit easier to work with:

https://github.com/lukebakken/rabbitmq-server-11148-11151

I can reproduce this error, but I have no idea what is going on. I'm hoping that @ansd can assist.

@ansd - please see the following repo with everything needed to reproduce:

https://github.com/lukebakken/rabbitmq-server-11148-11151?tab=readme-ov-file#reproduction-for-rabbitmqrabbitmq-server11148

0 replies

kjnilsson · 2024-05-07T15:05:41Z

kjnilsson
May 7, 2024
Maintainer

The issue is on closer inspection to do with the message id - currently it is set to an integer type in the sender, if you try setting it to a string type it may work better.

2 replies

lukebakken May 7, 2024
Maintainer

cc @sylvainrichardcool

Thanks @kjnilsson, indeed, if you change the code to this:

lukebakken/rabbitmq-server-11148-11151@5b9be59

...it works.

Though, the QPID proton docs state that an integer should work:

https://qpid.apache.org/releases/qpid-proton-0.39.0/proton/python/docs/proton.html#proton.Message.id

Answer selected by lukebakken

kjnilsson May 8, 2024
Maintainer

Yes it it a bug in RabbitMQ. We’ve effectively rewritten AMQP support for
4.0 so it will not exist there. 4.0 AMQP support will be first class. No
plugin needed.

sylvainrichardcool · 2024-05-13T07:38:52Z

sylvainrichardcool
May 13, 2024
Author

Thanks to both of you.
Waiting the RabbitMQ 4.0 version.

I noticed some problems in this version 3.13.1:

Id (message-id) must be string.
body must be encoded in Bytes for Stream Queue.
error are stack trace on RabbitMQ side, not readable : not a clear line with the error. (try catch usage)
no error on the client side (QPID proton python in my case)

I hope the 4.0 implementation will fix these shortcomings

Have a good day.

1 reply

ansd May 13, 2024
Maintainer

@sylvainrichardcool please try out rabbitmq-server main branch (future RabbitMQ 4.0) and provide feedback. Most AMQP 1.0 improvements already landed on main branch. You could use docker image pivotalrabbitmq/rabbitmq:main

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

AMQP1.0 - QPID Proton python sending message to RabbitMQ 3.13.1 Queue. #11148

{{title}}

{{editor}}'s edit

{{editor}}'s edit

Replies: 5 comments 3 replies

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{title}}

{{title}}

{{title}}

Select a reply

AMQP1.0 - QPID Proton python sending message to RabbitMQ 3.13.1 Queue. #11148

sylvainrichardcool May 2, 2024

Replies: 5 comments · 3 replies

lukebakken May 2, 2024 Maintainer

sylvainrichardcool May 2, 2024 Author

lukebakken May 6, 2024 Maintainer

kjnilsson May 7, 2024 Maintainer

lukebakken May 7, 2024 Maintainer

kjnilsson May 8, 2024 Maintainer

sylvainrichardcool May 13, 2024 Author

ansd May 13, 2024 Maintainer

sylvainrichardcool
May 2, 2024

Replies: 5 comments 3 replies

lukebakken
May 2, 2024
Maintainer

sylvainrichardcool
May 2, 2024
Author

lukebakken
May 6, 2024
Maintainer

kjnilsson
May 7, 2024
Maintainer

lukebakken May 7, 2024
Maintainer

kjnilsson May 8, 2024
Maintainer

sylvainrichardcool
May 13, 2024
Author

ansd May 13, 2024
Maintainer