[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