[rabbitmq-discuss] Experimenting with release candidates: RabbitMQ 2.7.9

Mon Mar 12 13:45:03 GMT 2012

Simon MacMullen <simon at rabbitmq.com> writes:
> Please, have a play with this and let us know if anything goes wrong
> for you...

One more problem: I get random failures with a test using STOMP and one topic.

Here is the test scenario:
 - two consumers (independent processes) are started on one topic
 - after a bit of time (to get the SUBSCRIBE+RECEIPT frames): two
   producers (independent processes) are started and send 5 messages
   each to the same topic
 - consumers end when they stop receiving new messages for several
   seconds
 - each consumer should have received 15 messages

Sometimes both consumers do get 15 messages but sometimes they get
less. The number of messages received varies: 15, 13, 12, 9...
The same test seems to work fine against RabbitMQ 2.7.1.

FWIW, I included a trace of what happens (including STOMP frames) for
one failure.

Cheers,

Lionel

# 2012/03/12-14:04:34 msak[10628]: incoming = broker (stomp://mybroker:6163)
# 2012/03/12-14:04:34 msak[10628]: Net::STOMP::Client->connect()
# 2012/03/12-14:04:34 msak[10628]:  encoded CONNECT frame
# 2012/03/12-14:04:34 msak[10628]:   H passcode:guest
# 2012/03/12-14:04:34 msak[10628]:   H accept-version:1.0,1.1
# 2012/03/12-14:04:34 msak[10628]:   H login:guest
# 2012/03/12-14:04:34 msak[10628]:   H host:rabbitmq
# 2012/03/12-14:04:34 msak[10628]:   sent 74 bytes
# 2012/03/12-14:04:34 msak[10629]: incoming = broker (stomp://mybroker:6163)
# 2012/03/12-14:04:34 msak[10628]:   received 100 bytes
# 2012/03/12-14:04:34 msak[10628]:  decoding CONNECTED frame
# 2012/03/12-14:04:34 msak[10628]:   H session:session-glmUUf49by_vwgLIsfaaQ6
# 2012/03/12-14:04:34 msak[10628]:   H heart-beat:0,0
# 2012/03/12-14:04:34 msak[10628]:   H server:RabbitMQ/2.7.9
# 2012/03/12-14:04:34 msak[10628]:   H version:1.1
# 2012/03/12-14:04:34 msak[10629]: Net::STOMP::Client->connect()
# 2012/03/12-14:04:34 msak[10629]:  encoded CONNECT frame
# 2012/03/12-14:04:34 msak[10629]:   H passcode:guest
# 2012/03/12-14:04:34 msak[10629]:   H accept-version:1.0,1.1
# 2012/03/12-14:04:34 msak[10629]:   H login:guest
# 2012/03/12-14:04:34 msak[10629]:   H host:rabbitmq
# 2012/03/12-14:04:34 msak[10629]:   sent 74 bytes
# 2012/03/12-14:04:34 msak[10629]:   received 100 bytes
# 2012/03/12-14:04:34 msak[10629]:  decoding CONNECTED frame
# 2012/03/12-14:04:34 msak[10629]:   H session:session-A8juhJ2SqmlAJcIkjrdiS2
# 2012/03/12-14:04:34 msak[10629]:   H heart-beat:0,0
# 2012/03/12-14:04:34 msak[10629]:   H server:RabbitMQ/2.7.9
# 2012/03/12-14:04:34 msak[10629]:   H version:1.1
# 2012/03/12-14:04:34 msak[10628]: Net::STOMP::Client->subscribe()
# 2012/03/12-14:04:34 msak[10628]:  encoded SUBSCRIBE frame
# 2012/03/12-14:04:34 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:34 msak[10628]:   H id:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:34 msak[10628]:   H receipt:94e6630-4f5df462-2984-6902-1
# 2012/03/12-14:04:34 msak[10628]:   sent 122 bytes
# 2012/03/12-14:04:34 msak[10628]: now waiting for the missing receipts
# 2012/03/12-14:04:34 msak[10629]: Net::STOMP::Client->subscribe()
# 2012/03/12-14:04:34 msak[10629]:  encoded SUBSCRIBE frame
# 2012/03/12-14:04:34 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:34 msak[10629]:   H id:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:34 msak[10629]:   H receipt:8978630-4f5df462-2985-ab87-1
# 2012/03/12-14:04:34 msak[10629]:   sent 122 bytes
# 2012/03/12-14:04:34 msak[10629]: now waiting for the missing receipts
# 2012/03/12-14:04:34 msak[10628]:   received 50 bytes
# 2012/03/12-14:04:34 msak[10628]:  decoding RECEIPT frame
# 2012/03/12-14:04:34 msak[10628]:   H receipt-id:94e6630-4f5df462-2984-6902-1
# 2012/03/12-14:04:34 msak[10628]: start
# 2012/03/12-14:04:34 msak[10629]:   received 50 bytes
# 2012/03/12-14:04:34 msak[10629]:  decoding RECEIPT frame
# 2012/03/12-14:04:34 msak[10629]:   H receipt-id:8978630-4f5df462-2985-ab87-1
# 2012/03/12-14:04:34 msak[10629]: start
# 2012/03/12-14:04:35 msak[10628]:   received 0 bytes
# 2012/03/12-14:04:35 msak[10628]: got no message (no frames received)
# 2012/03/12-14:04:35 msak[10629]:   received 0 bytes
# 2012/03/12-14:04:35 msak[10629]: got no message (no frames received)
# 2012/03/12-14:04:36 msak[10632]: incoming = generator
# 2012/03/12-14:04:36 msak[10632]: outgoing = broker (stomp://mybroker:6163)
# 2012/03/12-14:04:36 msak[10628]:   received 0 bytes
# 2012/03/12-14:04:36 msak[10628]: got no message (no frames received)
# 2012/03/12-14:04:36 msak[10632]: Net::STOMP::Client->connect()
# 2012/03/12-14:04:36 msak[10629]:   received 0 bytes
# 2012/03/12-14:04:36 msak[10629]: got no message (no frames received)
# 2012/03/12-14:04:36 msak[10632]:  encoded CONNECT frame
# 2012/03/12-14:04:36 msak[10632]:   H passcode:guest
# 2012/03/12-14:04:36 msak[10632]:   H accept-version:1.0,1.1
# 2012/03/12-14:04:36 msak[10632]:   H login:guest
# 2012/03/12-14:04:36 msak[10632]:   H host:rabbitmq
# 2012/03/12-14:04:36 msak[10632]:   sent 74 bytes
# 2012/03/12-14:04:36 msak[10632]:   received 100 bytes
# 2012/03/12-14:04:36 msak[10632]:  decoding CONNECTED frame
# 2012/03/12-14:04:36 msak[10632]:   H session:session-wUavc52XJm4ReMchKZVtor
# 2012/03/12-14:04:36 msak[10632]:   H heart-beat:0,0
# 2012/03/12-14:04:36 msak[10632]:   H server:RabbitMQ/2.7.9
# 2012/03/12-14:04:36 msak[10632]:   H version:1.1
# 2012/03/12-14:04:36 msak[10632]: start
# 2012/03/12-14:04:36 msak[10632]: got message 1
# 2012/03/12-14:04:36 msak[10632]: outgoing message <no-message-id>
# 2012/03/12-14:04:36 msak[10632]:  encoded SEND frame
# 2012/03/12-14:04:36 msak[10632]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:36 msak[10632]:   H content-length:1
# 2012/03/12-14:04:36 msak[10632]:   B 0000 31                                   1
# 2012/03/12-14:04:36 msak[10632]:   sent 66 bytes
# 2012/03/12-14:04:36 msak[10632]: got message 2
# 2012/03/12-14:04:36 msak[10628]:   received 188 bytes
# 2012/03/12-14:04:36 msak[10629]:   received 188 bytes
# 2012/03/12-14:04:36 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:36 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:36 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:36 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:36 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:36 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:36 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@1
# 2012/03/12-14:04:36 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@1
# 2012/03/12-14:04:36 msak[10628]:   H content-length:1
# 2012/03/12-14:04:36 msak[10629]:   H content-length:1
# 2012/03/12-14:04:36 msak[10628]:   B 0000 31                                   1
# 2012/03/12-14:04:36 msak[10629]:   B 0000 31                                   1
# 2012/03/12-14:04:36 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@1
# 2012/03/12-14:04:36 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@1
# 2012/03/12-14:04:36 msak[10628]: got message 1
# 2012/03/12-14:04:36 msak[10629]: got message 1
# 2012/03/12-14:04:36 msak[10632]: outgoing message <no-message-id>
# 2012/03/12-14:04:36 msak[10632]:  encoded SEND frame
# 2012/03/12-14:04:36 msak[10632]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:36 msak[10632]:   H content-length:1
# 2012/03/12-14:04:36 msak[10632]:   B 0000 32                                   2
# 2012/03/12-14:04:36 msak[10632]:   sent 66 bytes
# 2012/03/12-14:04:36 msak[10632]: got message 3
# 2012/03/12-14:04:36 msak[10632]: outgoing message <no-message-id>
# 2012/03/12-14:04:36 msak[10632]:  encoded SEND frame
# 2012/03/12-14:04:36 msak[10632]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:36 msak[10632]:   H content-length:1
# 2012/03/12-14:04:36 msak[10632]:   B 0000 33                                   3
# 2012/03/12-14:04:36 msak[10632]:   sent 66 bytes
# 2012/03/12-14:04:36 msak[10632]: got message 4
# 2012/03/12-14:04:36 msak[10632]: outgoing message <no-message-id>
# 2012/03/12-14:04:36 msak[10632]:  encoded SEND frame
# 2012/03/12-14:04:36 msak[10632]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:36 msak[10632]:   H content-length:1
# 2012/03/12-14:04:36 msak[10632]:   B 0000 34                                   4
# 2012/03/12-14:04:36 msak[10632]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10632]: got message 5
# 2012/03/12-14:04:37 msak[10632]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10632]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10632]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10632]:   H content-length:1
# 2012/03/12-14:04:37 msak[10632]:   B 0000 35                                   5
# 2012/03/12-14:04:37 msak[10632]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10632]: stop
# 2012/03/12-14:04:37 msak[10632]:   received 0 bytes
# 2012/03/12-14:04:37 msak[10632]: Net::STOMP::Client->disconnect()
# 2012/03/12-14:04:37 msak[10632]:  encoded DISCONNECT frame
# 2012/03/12-14:04:37 msak[10632]:   sent 13 bytes
# 2012/03/12-14:04:37 msak[10628]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10629]:   received 376 bytes
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@2
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@2
# 2012/03/12-14:04:37 msak[10628]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@2
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@2
# 2012/03/12-14:04:37 msak[10628]: got message 2
# 2012/03/12-14:04:37 msak[10629]: got message 2
# 2012/03/12-14:04:37 msak[10628]:   received 564 bytes
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@3
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@3
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10628]:   B 0000 33                                   3
# 2012/03/12-14:04:37 msak[10629]:   B 0000 33                                   3
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@3
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@3
# 2012/03/12-14:04:37 msak[10629]: got message 3
# 2012/03/12-14:04:37 msak[10628]: got message 3
# 2012/03/12-14:04:37 msak[10629]:   received 376 bytes
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@4
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@4
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10628]:   B 0000 34                                   4
# 2012/03/12-14:04:37 msak[10629]:   B 0000 34                                   4
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@4
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@4
# 2012/03/12-14:04:37 msak[10629]: got message 4
# 2012/03/12-14:04:37 msak[10628]: got message 4
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@5
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10628]:   B 0000 35                                   5
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@5
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   B 0000 35                                   5
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@5
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@5
# 2012/03/12-14:04:37 msak[10628]: got message 5
# 2012/03/12-14:04:37 msak[10629]: got message 5
# 2012/03/12-14:04:37 msak[10630]: incoming = generator
# 2012/03/12-14:04:37 msak[10630]: outgoing = broker (stomp://mybroker:6163)
# 2012/03/12-14:04:37 msak[10630]: Net::STOMP::Client->connect()
# 2012/03/12-14:04:37 msak[10630]:  encoded CONNECT frame
# 2012/03/12-14:04:37 msak[10630]:   H passcode:guest
# 2012/03/12-14:04:37 msak[10630]:   H accept-version:1.0,1.1
# 2012/03/12-14:04:37 msak[10630]:   H login:guest
# 2012/03/12-14:04:37 msak[10630]:   H host:rabbitmq
# 2012/03/12-14:04:37 msak[10630]:   sent 74 bytes
# 2012/03/12-14:04:37 msak[10630]:   received 100 bytes
# 2012/03/12-14:04:37 msak[10630]:  decoding CONNECTED frame
# 2012/03/12-14:04:37 msak[10630]:   H session:session-gqfAux5SEWpJpzU646S9E1
# 2012/03/12-14:04:37 msak[10630]:   H heart-beat:0,0
# 2012/03/12-14:04:37 msak[10630]:   H server:RabbitMQ/2.7.9
# 2012/03/12-14:04:37 msak[10630]:   H version:1.1
# 2012/03/12-14:04:37 msak[10631]: incoming = generator
# 2012/03/12-14:04:37 msak[10631]: outgoing = broker (stomp://mybroker:6163)
# 2012/03/12-14:04:37 msak[10631]: Net::STOMP::Client->connect()
# 2012/03/12-14:04:37 msak[10631]:  encoded CONNECT frame
# 2012/03/12-14:04:37 msak[10631]:   H passcode:guest
# 2012/03/12-14:04:37 msak[10631]:   H accept-version:1.0,1.1
# 2012/03/12-14:04:37 msak[10631]:   H login:guest
# 2012/03/12-14:04:37 msak[10631]:   H host:rabbitmq
# 2012/03/12-14:04:37 msak[10631]:   sent 74 bytes
# 2012/03/12-14:04:37 msak[10631]:   received 100 bytes
# 2012/03/12-14:04:37 msak[10631]:  decoding CONNECTED frame
# 2012/03/12-14:04:37 msak[10631]:   H session:session-Qa7zCIwbfrU6mYAMB0hWhO
# 2012/03/12-14:04:37 msak[10631]:   H heart-beat:0,0
# 2012/03/12-14:04:37 msak[10631]:   H server:RabbitMQ/2.7.9
# 2012/03/12-14:04:37 msak[10631]:   H version:1.1
# 2012/03/12-14:04:37 msak[10630]: start
# 2012/03/12-14:04:37 msak[10630]: got message 1
# 2012/03/12-14:04:37 msak[10630]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10630]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10630]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10630]:   H content-length:1
# 2012/03/12-14:04:37 msak[10630]:   B 0000 31                                   1
# 2012/03/12-14:04:37 msak[10630]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10630]: got message 2
# 2012/03/12-14:04:37 msak[10630]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10628]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10629]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@6
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@6
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10628]:   B 0000 31                                   1
# 2012/03/12-14:04:37 msak[10629]:   B 0000 31                                   1
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@6
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@6
# 2012/03/12-14:04:37 msak[10628]: got message 6
# 2012/03/12-14:04:37 msak[10629]: got message 6
# 2012/03/12-14:04:37 msak[10630]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10630]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10630]:   H content-length:1
# 2012/03/12-14:04:37 msak[10630]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10630]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10630]: got message 3
# 2012/03/12-14:04:37 msak[10630]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10630]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10630]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10630]:   H content-length:1
# 2012/03/12-14:04:37 msak[10630]:   B 0000 33                                   3
# 2012/03/12-14:04:37 msak[10630]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10630]: got message 4
# 2012/03/12-14:04:37 msak[10630]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10630]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10630]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10630]:   H content-length:1
# 2012/03/12-14:04:37 msak[10630]:   B 0000 34                                   4
# 2012/03/12-14:04:37 msak[10630]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10630]: got message 5
# 2012/03/12-14:04:37 msak[10630]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10630]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10630]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10630]:   H content-length:1
# 2012/03/12-14:04:37 msak[10630]:   B 0000 35                                   5
# 2012/03/12-14:04:37 msak[10630]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10630]: stop
# 2012/03/12-14:04:37 msak[10630]:   received 0 bytes
# 2012/03/12-14:04:37 msak[10630]: Net::STOMP::Client->disconnect()
# 2012/03/12-14:04:37 msak[10630]:  encoded DISCONNECT frame
# 2012/03/12-14:04:37 msak[10630]:   sent 13 bytes
# 2012/03/12-14:04:37 msak[10628]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10629]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@7
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@7
# 2012/03/12-14:04:37 msak[10628]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@7
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@7
# 2012/03/12-14:04:37 msak[10628]: got message 7
# 2012/03/12-14:04:37 msak[10629]: got message 7
# 2012/03/12-14:04:37 msak[10631]: start
# 2012/03/12-14:04:37 msak[10631]: got message 1
# 2012/03/12-14:04:37 msak[10631]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10631]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10631]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10631]:   H content-length:1
# 2012/03/12-14:04:37 msak[10631]:   B 0000 31                                   1
# 2012/03/12-14:04:37 msak[10631]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10631]: got message 2
# 2012/03/12-14:04:37 msak[10631]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10629]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10628]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@8
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   B 0000 31                                   1
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@8
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@8
# 2012/03/12-14:04:37 msak[10628]:   B 0000 31                                   1
# 2012/03/12-14:04:37 msak[10629]: got message 8
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@8
# 2012/03/12-14:04:37 msak[10631]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10631]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]: got message 8
# 2012/03/12-14:04:37 msak[10631]:   H content-length:1
# 2012/03/12-14:04:37 msak[10631]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10631]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10631]: got message 3
# 2012/03/12-14:04:37 msak[10631]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10631]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10631]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10631]:   H content-length:1
# 2012/03/12-14:04:37 msak[10631]:   B 0000 33                                   3
# 2012/03/12-14:04:37 msak[10631]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10631]: got message 4
# 2012/03/12-14:04:37 msak[10631]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10631]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10631]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10631]:   H content-length:1
# 2012/03/12-14:04:37 msak[10631]:   B 0000 34                                   4
# 2012/03/12-14:04:37 msak[10631]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10631]: got message 5
# 2012/03/12-14:04:37 msak[10631]: outgoing message <no-message-id>
# 2012/03/12-14:04:37 msak[10631]:  encoded SEND frame
# 2012/03/12-14:04:37 msak[10631]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10631]:   H content-length:1
# 2012/03/12-14:04:37 msak[10631]:   B 0000 35                                   5
# 2012/03/12-14:04:37 msak[10631]:   sent 66 bytes
# 2012/03/12-14:04:37 msak[10631]: stop
# 2012/03/12-14:04:37 msak[10631]:   received 0 bytes
# 2012/03/12-14:04:37 msak[10631]: Net::STOMP::Client->disconnect()
# 2012/03/12-14:04:37 msak[10631]:  encoded DISCONNECT frame
# 2012/03/12-14:04:37 msak[10631]:   sent 13 bytes
# 2012/03/12-14:04:37 msak[10629]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10628]:   received 188 bytes
# 2012/03/12-14:04:37 msak[10629]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10628]:  decoding MESSAGE frame
# 2012/03/12-14:04:37 msak[10629]:   H subscription:8978630-4f5df462-2985-ab87-2
# 2012/03/12-14:04:37 msak[10629]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10628]:   H subscription:94e6630-4f5df462-2984-6902-2
# 2012/03/12-14:04:37 msak[10629]:   H message-id:T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@9
# 2012/03/12-14:04:37 msak[10628]:   H destination:/topic/test.mbtf.bb.d9d20365
# 2012/03/12-14:04:37 msak[10629]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10628]:   H message-id:T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@9
# 2012/03/12-14:04:37 msak[10628]:   H content-length:1
# 2012/03/12-14:04:37 msak[10629]: incoming message T_8978630-4f5df462-2985-ab87-2@@session-A8juhJ2SqmlAJcIkjrdiS2@@9
# 2012/03/12-14:04:37 msak[10628]:   B 0000 32                                   2
# 2012/03/12-14:04:37 msak[10629]: got message 9
# 2012/03/12-14:04:37 msak[10628]: incoming message T_94e6630-4f5df462-2984-6902-2@@session-glmUUf49by_vwgLIsfaaQ6@@9
# 2012/03/12-14:04:37 msak[10628]: got message 9
# 2012/03/12-14:04:38 msak[10629]:   received 0 bytes
# 2012/03/12-14:04:38 msak[10629]: got no message (no frames received)
# 2012/03/12-14:04:38 msak[10628]:   received 0 bytes
# 2012/03/12-14:04:38 msak[10628]: got no message (no frames received)
# 2012/03/12-14:04:39 msak[10629]:   received 0 bytes
# 2012/03/12-14:04:39 msak[10629]: got no message (no frames received)
# 2012/03/12-14:04:39 msak[10628]:   received 0 bytes
# 2012/03/12-14:04:39 msak[10628]: got no message (no frames received)
# 2012/03/12-14:04:40 msak[10629]:   received 0 bytes
# 2012/03/12-14:04:40 msak[10629]: got no message (no frames received)
# 2012/03/12-14:04:40 msak[10628]:   received 0 bytes
# 2012/03/12-14:04:40 msak[10628]: got no message (no frames received)
# 2012/03/12-14:04:41 msak[10629]:   received 0 bytes
# 2012/03/12-14:04:41 msak[10629]: stop
# 2012/03/12-14:04:41 msak[10629]:   received 0 bytes
# 2012/03/12-14:04:41 msak[10629]: Net::STOMP::Client->disconnect()
# 2012/03/12-14:04:41 msak[10628]:   received 0 bytes
# 2012/03/12-14:04:41 msak[10629]:  encoded DISCONNECT frame
# 2012/03/12-14:04:41 msak[10628]: stop
# 2012/03/12-14:04:41 msak[10629]:   sent 13 bytes
# 2012/03/12-14:04:41 msak[10628]:   received 0 bytes
# 2012/03/12-14:04:41 msak[10628]: Net::STOMP::Client->disconnect()
# 2012/03/12-14:04:41 msak[10628]:  encoded DISCONNECT frame
# 2012/03/12-14:04:41 msak[10628]:   sent 13 bytes
count: FAIL: unexpected number of messages received by consumer1: 9 instead of 15