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

Fri Feb 4 08:25:10 GMT 2011

On 3 Vas, 01:51, Matthew Sackman <matt... at rabbitmq.com> wrote:
> On Wed, Feb 02, 2011 at 11:48:19PM +0000, Matthew Sackman wrote:
> > Ok, so the message payload is being sent through as a list instead of as
> > a binary. My guess without checking further is this is a bug in the
> > stomp client in the way it constructs the messages which are then sent
> > further into Rabbit, but this may not be the case.
>
> I meant "stomp adaptor" there, not client.
>
> Matthew
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

Hi,

Hmm, we use python (and java) as amqp client. And use some javascript
(http://www.orbited.org) through stomp to connect to rabbitmq.

I have debugged with wireshark and attached send command from orbited
(proxy) to rabbitmq.
Debug log from javascript and simple javascropt is also added below.
About code (parameters) for javascript: orbited runs on
127.0.0.1:9000. Passthrough to rabbitmq with stomp plugin on same
machine.
---

0000   53 45 4e 44 0a 63 6f 6e 74 65 6e 74 2d 74 79 70  SEND.content-
typ
0010   65 3a 74 65 78 74 2f 70 6c 61 69 6e 0a 63 6f 6e  e:text/
plain.con
0020   74 65 6e 74 2d 65 6e 63 6f 64 69 6e 67 3a 75 74  tent-
encoding:ut
0030   66 2d 38 0a 63 6f 6e 74 65 6e 74 2d 6c 65 6e 67  f-8.content-
leng
0040   74 68 3a 31 38 0a 64 65 73 74 69 6e 61 74 69 6f  th:
18.destinatio
0050   6e 3a 2f 65 78 63 68 61 6e 67 65 2f 68 6d 2f 74  n:/exchange/hm/
t
0060   65 73 74 2e 73 74 6f 6d 70 0a 0a 6d 65 73 73 61
est.stomp..messa
0070   67 65 5f 66 72 6f 6d 5f 73 74 6f 6d 70 00        ge_from_stomp.

--

Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, sessionOpen; sending:, 127.0.0.1:61613
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, encoded payload:, 127.0.0.1:61613
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, initial
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, data, 1
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, len, 1
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, typeof(data), string
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, data[0] , 1
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, type , string
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, result, true
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, tcpsocket.onopen..
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, SEND: , CONNECT login:guest passcode:guest �
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, did onopen
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, READ: , CONNECTED session:session-
B91MWlC45wxuqYty86zZVg== heartbeat:0,0 version:1.0 �
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, SEND: , SEND content-type:text/plain content-
encoding:utf-8 content-length:18 destination:/exchange/hm/test.stomp
message_from_stomp�
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, SEND: , DISCONNECT �
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, sessionOnClose
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, doClose, 201
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, onCloseTriggered, false
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, triggerClose timer, 201
Fri Feb 04 2011 09:16:24 GMT+0200 (FLE Standard Time), debug,
Orbited.TCPSocket, onclose!, 201

---

<html>
<head>

<script type="text/javascript">document.domain = document.domain;</
script>

<title>STOMP test</title>

<script type="text/javascript" src="jquery-1.4.4.min.js"></script>

<script type="text/javascript" src="http://127.0.0.1:9000/static/
Orbited.js"></script>
<script type="text/javascript">
Orbited.settings.hostname = "127.0.0.1";
Orbited.settings.port = 9000;

Orbited.loggers['Orbited.TCPSocket'].enabled = true;
Orbited.settings.log = true;

TCPSocket = Orbited.TCPSocket;
</script>
<script type="text/javascript" src="http://127.0.0.1:9000/static/
protocols/stomp/stomp.js"></script>
<script type="text/javascript">
function send_to_stomp() {
  stomp = new STOMPClient();
  stomp.onconnectedframe = function() {
    stomp.send('message_from_stomp', '/exchange/hm/test.stomp');
    stomp.disconnect();
  };
  stomp.connect('127.0.0.1', 61613, 'guest', 'guest')
}
</script>
</head>
<body>
<button onclick="send_to_stomp()">send</button>
</body>
</html>