[rabbitmq-discuss] RabbitMQ 2.2.0 message delivery issue: internal crash

[Alfonso Pantoja]

Hi,

We are experiencing an issue with version 2.2.0 which causes to
RabbitMQ to not deliver messages to a consumer.
The consumer is connected to RabbitMQ and performs a create queue/
exchange/binding when it is started but sometimes when there are
messages in the queue they are not being delivered by Rabbit.
Restarting the consumer (it is a windows service) does not solve the
problem and the consumer remains connected but without any message
although the queue contains 3000 messages.

I've found this in rabbitmq sals log file every time I restart the
service:


=CRASH REPORT==== 17-Aug-2011::11:19:04 ===
  crasher:
    initial call: rabbit_writer:mainloop/2
    pid: <0.5938.552>
    registered_name: []
    exception error: bad argument
      in function  rabbit_binary_generator:encode_property/2
      in call from rabbit_binary_generator:encode_properties/6
      in call from rabbit_binary_generator:ensure_content_encoded/2
      in call from rabbit_binary_generator:build_simple_content_frames/
4
      in call from rabbit_writer:assemble_frames/5
      in call from rabbit_writer:internal_send_command_async/3
      in call from rabbit_writer:handle_message/2
      in call from rabbit_writer:mainloop1/2
    ancestors: [<0.5937.552>,<0.5912.552>,<0.5910.552>,
                  rabbit_tcp_client_sup,rabbit_sup,<0.165.0>]
    messages: [{send_command_and_notify,<0.463.0>,<0.5939.552>,
                      {'basic.deliver',
                          <<"amq.ctag-Ci6dSa3Tdm2obfV5CXFVxg==">>,
2,false,
                          <<"users">>,<<"domain.com.machinename.
0.status">>},
                      {content,60,
                          {'P_basic',<<"text/
plain">>,undefined,undefined,2,
                              undefined,undefined,undefined,undefined,
                              undefined,
1920007482.523,undefined,undefined,
                              undefined,undefined},
                          none,none,
                          [<<"<presence><jid>username1 at domain.com</
jid><status>offline</status></presence>">>]}},
                  {send_command_and_notify,<0.463.0>,<0.5939.552>,
                      {'basic.deliver',
                          <<"amq.ctag-Ci6dSa3Tdm2obfV5CXFVxg==">>,
3,false,
                          <<"users">>,<<"domain.com.machinename.
0.status">>},
                      {content,60,
                          {'P_basic',<<"text/
plain">>,undefined,undefined,2,
                              undefined,undefined,undefined,undefined,
                              undefined,
1920009454.965,undefined,undefined,
                              undefined,undefined},
                          none,none,
                          [<<"<presence><jid>username2 at domain.com</
jid><status>online</status></presence>">>]}},
                  {send_command_and_notify,<0.463.0>,<0.5939.552>,
                      {'basic.deliver',
                          <<"amq.ctag-Ci6dSa3Tdm2obfV5CXFVxg==">>,
4,false,
                          <<"users">>,<<"domain.com.machinename.
0.status">>},


.
.
.


[log reduced for clarity]

.
.
.


    links: [<0.5937.552>]
    dictionary: []
    trap_exit: false
    status: running
    heap_size: 987
    stack_size: 24
    reductions: 194
  neighbours:

=SUPERVISOR REPORT==== 17-Aug-2011::11:19:04 ===
     Supervisor: {<0.5937.552>,rabbit_channel_sup}
     Context:    child_terminated
     Reason:     badarg
     Offender:   [{pid,<0.5938.552>},
                  {name,writer},
                  {mfa,{rabbit_writer,start_link,
                                      [#Port<0.8712>,1,131072,
                                       rabbit_framing_amqp_0_9_1,
                                       <0.5913.552>]}},
                  {restart_type,intrinsic},
                  {shutdown,4294967295},
                  {child_type,worker}]


=SUPERVISOR REPORT==== 17-Aug-2011::11:19:04 ===
     Supervisor: {<0.5937.552>,rabbit_channel_sup}
     Context:    shutdown
     Reason:     reached_max_restart_intensity
     Offender:   [{pid,<0.5938.552>},
                  {name,writer},
                  {mfa,{rabbit_writer,start_link,
                                      [#Port<0.8712>,1,131072,
                                       rabbit_framing_amqp_0_9_1,
                                       <0.5913.552>]}},
                  {restart_type,intrinsic},
                  {shutdown,4294967295},
                  {child_type,worker}]



Note: "<presence><jid>username1 at domain.com</jid><status>offline</
status></presence>" is a message on the queue and
"domain.com.machinename.0.status" is the routing key.