[rabbitmq-discuss] Sending message through rabbitmq-stomp -> exchange(topic) - crashes queue

Jurdanas Kriauciunas jurdanas.kriauciunas at gmail.com
Wed Feb 2 18:27:45 GMT 2011


Hi,

I have a problem with rabbitmq-stomp sending to exchange and receiving
messages through amqp.
In example I create exchange (type=topic): hm
Python clients creates "anonymous" queue and binds to exchange: hm.
with test.# routing key pattern.
Stomp client sends message to destination: /exchange/hm/test.stompkey

At this time "anonymous" queue dies. It also can be seen from web
management.
Interestingly stomp to stomp through rabbitmq works ok. (eg. subscribe
send). Also stomp can receive messages sent from python (or java)
client without big problems.
Versions tested: 2.1.1, 2.2.0 and newest 2.3.0. All have same problem
(2.1.1 has different destination naming and extra headers). But newest
version sends error back at least.

---
Here is excerpt from .log file:
=ERROR REPORT==== 2-Feb-2011::19:50:38 ===
Error in process <0.2811.0> on node 'rabbit at JOSKIS-PC' with exit
value: {badarg,[{erlang,size,[[<<9 bytes>>]]},
{rabbit_binary_generator,build_content_frames,7},
{rabbit_binary_generator,build_simple_content_frames,4},
{rabbit_writer,assemble_frames,5},
{rabbit_writer,internal_send_command_async...


=ERROR REPORT==== 2-Feb-2011::19:50:38 ===
connection <0.2809.0> (running), channel 1 - error:
shutdown

=WARNING REPORT==== 2-Feb-2011::19:50:38 ===
Non-AMQP exit reason 'shutdown'

=INFO REPORT==== 2-Feb-2011::19:50:38 ===
closing TCP connection <0.2809.0> from 127.0.0.1:64551

=INFO REPORT==== 2-Feb-2011::19:51:38 ===
accepted TCP connection on 0.0.0.0:5672 from 127.0.0.1:64562

=INFO REPORT==== 2-Feb-2011::19:51:38 ===
starting TCP connection <0.3603.0> from 127.0.0.1:64562

=INFO REPORT==== 2-Feb-2011::19:51:38 ===
closing TCP connection <0.3603.0> from 127.0.0.1:64562

=INFO REPORT==== 2-Feb-2011::19:51:47 ===
accepted TCP connection on 0.0.0.0:5672 from 127.0.0.1:64565

=INFO REPORT==== 2-Feb-2011::19:51:47 ===
starting TCP connection <0.3706.0> from 127.0.0.1:64565

=ERROR REPORT==== 2-Feb-2011::19:51:51 ===
connection <0.3706.0> (running), channel 1 - error:
shutdown

=WARNING REPORT==== 2-Feb-2011::19:51:51 ===
Non-AMQP exit reason 'shutdown'

=INFO REPORT==== 2-Feb-2011::19:51:51 ===
closing TCP connection <0.3706.0> from 127.0.0.1:64565

=INFO REPORT==== 2-Feb-2011::19:53:58 ===
ending STOMP connection <0.1344.0> from 127.0.0.1:64522


---
Here is excerpt from -sasl.log file:

=SUPERVISOR REPORT==== 2-Feb-2011::19:50:38 ===
     Supervisor: {<0.2810.0>,rabbit_channel_sup}
     Context:    child_terminated
     Reason:     {badarg,
                     [{erlang,size,[[<<"how are u">>]]},
                      {rabbit_binary_generator,build_content_frames,
7},
 
{rabbit_binary_generator,build_simple_content_frames,4},
                      {rabbit_writer,assemble_frames,5},
                      {rabbit_writer,internal_send_command_async,3},
                      {rabbit_writer,handle_message,2},
                      {rabbit_writer,mainloop1,2},
                      {rabbit_writer,mainloop,2}]}
     Offender:   [{pid,<0.2811.0>},
                  {name,writer},
                  {mfa,{rabbit_writer,start_link,
                                      [#Port<0.4445>,1,131072,
 
rabbit_framing_amqp_0_8,<0.2809.0>]}},
                  {restart_type,intrinsic},
                  {shutdown,4294967295},
                  {child_type,worker}]


=SUPERVISOR REPORT==== 2-Feb-2011::19:50:38 ===
     Supervisor: {<0.2810.0>,rabbit_channel_sup}
     Context:    shutdown
     Reason:     reached_max_restart_intensity
     Offender:   [{pid,<0.2811.0>},
                  {name,writer},
                  {mfa,{rabbit_writer,start_link,
                                      [#Port<0.4445>,1,131072,
 
rabbit_framing_amqp_0_8,<0.2809.0>]}},
                  {restart_type,intrinsic},
                  {shutdown,4294967295},
                  {child_type,worker}]


=CRASH REPORT==== 2-Feb-2011::19:51:51 ===
  crasher:
    initial call: rabbit_writer:mainloop/2
    pid: <0.3708.0>
    registered_name: []
    exception error: bad argument
      in function  size/1
         called as size([<<"how are u">>])
      in call from rabbit_binary_generator:build_content_frames/7
      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
      in call from rabbit_writer:mainloop/2
    ancestors:
[<0.3707.0>,<0.3705.0>,<0.3703.0>,rabbit_tcp_client_sup,
                  rabbit_sup,<0.70.0>]
    messages: []
    links: [<0.3707.0>]
    dictionary: []
    trap_exit: false
    status: running
    heap_size: 377
    stack_size: 24
    reductions: 218
  neighbours:

=SUPERVISOR REPORT==== 2-Feb-2011::19:51:51 ===
     Supervisor: {<0.3707.0>,rabbit_channel_sup}
     Context:    child_terminated
     Reason:     badarg
     Offender:   [{pid,<0.3708.0>},
                  {name,writer},
                  {mfa,{rabbit_writer,start_link,
                                      [#Port<0.4449>,1,131072,
 
rabbit_framing_amqp_0_8,<0.3706.0>]}},
                  {restart_type,intrinsic},
                  {shutdown,4294967295},
                  {child_type,worker}]


=SUPERVISOR REPORT==== 2-Feb-2011::19:51:51 ===
     Supervisor: {<0.3707.0>,rabbit_channel_sup}
     Context:    shutdown
     Reason:     reached_max_restart_intensity
     Offender:   [{pid,<0.3708.0>},
                  {name,writer},
                  {mfa,{rabbit_writer,start_link,
                                      [#Port<0.4449>,1,131072,
 
rabbit_framing_amqp_0_8,<0.3706.0>]}},
                  {restart_type,intrinsic},
                  {shutdown,4294967295},
                  {child_type,worker}]


More information about the rabbitmq-discuss mailing list