Hello Qpid community,
I’m testing the resilience of a dispatcher/broker infrastructure and I
noticed the following behavior:
I run a test with one JMS client connected to a dispatcher, which is
connected to a broker.
1) Using JMS I establish a connection to the dispatcher and create a
message producer
2) I’m able to send a message to the broker through the dispatcher
3) I stop and restart the broker
4) I cannot send any messages using the message producer I created
before.
5) If a recreate a MessageProducer (new AMQP link), the message
arrives to the broker
In the failing scenario 4, I noticed using Wireshark that the dispatcher
does not send any messages to the broker. So I deduced that the broker is
not responsible for this behavior.
*Is it an expected behavior? What can I change in the dispatcher/JMS
configuration to avoid the failure?*
You can find attached the Wireshark logs I produced from this experiment:
- JMS – dispatcher – reuse sender: logs between JMS and the
dispatcher when I reuse the message producer after the restart
- JMS – dispatcher – new sender: logs between JMS and the
dispatcher when I create a new message producer after the restart
- dispatcher – broker – reuse sender: logs between the dispatcher
and the broker, I reuse the message producer
- dispatcher – broker – reuse sender: logs between the dispatcher
and the broker, I create a new message producer
I’m using qpid-dispatch 0.6.0, JMS 0.9.0 and qpid-java-broker 6.0.1.
Thanks,
Best regards,
Antoine
src.ip = JMS ip
dst.ip = dispatcher ip
# Client connection
Source Destination Protocol Length Info
src.ip dst.ip TCP 66 53505 â 5672 [SYN] Seq=0
Win=65535 Len=0 MSS=1460 WS=2 SACK_PERM=1
dst.ip src.ip TCP 66 5672 â 53505 [SYN, ACK]
Seq=0 Ack=1 Win=29200 Len=0 MSS=1460 SACK_PERM=1 WS=128
src.ip dst.ip TCP 54 53505 â 5672 [ACK] Seq=1
Ack=1 Win=65536 Len=0
src.ip dst.ip AMQP 62 Protocol-Header 1-0-0
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=1
Ack=9 Win=29312 Len=0
dst.ip src.ip AMQP 105 Protocol-Header 1-0-0
sasl.mechanisms
src.ip dst.ip AMQP 91 sasl.init
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=52
Ack=46 Win=29312 Len=0
dst.ip src.ip AMQP 76 sasl.outcome
src.ip dst.ip AMQP 300 Protocol-Header 1-0-0 open
dst.ip src.ip AMQP 185 Protocol-Header 1-0-0 open
# Creating the Session
src.ip dst.ip AMQP 86 begin
dst.ip src.ip AMQP 86 begin
src.ip dst.ip AMQP 86 begin
dst.ip src.ip AMQP 86 begin
# Creating MessageProducer
src.ip dst.ip AMQP 313 attach
dst.ip src.ip AMQP 374 attach flow
# Sending a message (success)
src.ip dst.ip AMQP 405 transfer
dst.ip src.ip AMQP 131 flow disposition
src.ip dst.ip TCP 54 53505 â 5672 [ACK] Seq=966
Ack=666 Win=64870 Len=0
src.ip dst.ip AMQP 62 (empty)
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=666
Ack=974 Win=32512 Len=0
src.ip dst.ip AMQP 62 (empty)
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=666
Ack=982 Win=32512 Len=0
dst.ip src.ip AMQP 62 (empty)
# Stopping broker
src.ip dst.ip TCP 54 53505 â 5672 [ACK] Seq=982
Ack=674 Win=64862 Len=0
src.ip dst.ip AMQP 62 (empty)
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=674
Ack=990 Win=32512 Len=0
# Trying to send a message (timeout)
src.ip dst.ip AMQP 406 transfer
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=674
Ack=1342 Win=33536 Len=0
src.ip dst.ip AMQP 62 (empty)
# Restarting broker
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=674
Ack=1350 Win=33536 Len=0
# Trying to send a message (timeout)
src.ip dst.ip AMQP 405 transfer
dst.ip src.ip TCP 60 5672 â 53505 [ACK] Seq=674
Ack=1701 Win=34560 Len=0
dst.ip src.ip AMQP 62 (empty)
src.ip dst.ip TCP 54 53505 â 5672 [ACK]
Seq=1701 Ack=682 Win=64854 Len=0
src.ip dst.ip TCP 54 53505 â 5672 [RST, ACK]
Seq=1701 Ack=682 Win=0 Len=0
dst.ip = dispatcher ip
src.ip = broker ip
# Connecting the dispatcher to the broker
Source Destination Protocol Length Info
dst.ip src.ip TCP 74 41592 â 5672 [SYN] Seq=0
Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174618823 TSecr=0 WS=128
src.ip dst.ip TCP 74 5672 â 41592 [SYN, ACK]
Seq=0 Ack=1 Win=8192 Len=0 MSS=1460 WS=256 SACK_PERM=1 TSval=456950635
TSecr=174618823
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=1
Ack=1 Win=29312 Len=0 TSval=174618823 TSecr=456950635
dst.ip src.ip AMQP 74 Protocol-Header 1-0-0
src.ip dst.ip TCP 66 5672 â 41592 [ACK] Seq=1
Ack=9 Win=262144 Len=0 TSval=456950635 TSecr=174618823
src.ip dst.ip AMQP 102 Protocol-Header 1-0-0
sasl.mechanisms
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=9
Ack=37 Win=29312 Len=0 TSval=174618824 TSecr=456950635
dst.ip src.ip AMQP 117 sasl.init
src.ip dst.ip AMQP 90 sasl.outcome Protocol-Header
1-0-0
dst.ip src.ip AMQP 219 Protocol-Header 1-0-0 open
src.ip dst.ip AMQP 215 open
dst.ip src.ip AMQP 219 begin attach
dst.ip src.ip AMQP 220 begin attach
src.ip dst.ip TCP 66 5672 â 41592 [ACK] Seq=210
Ack=520 Win=261632 Len=0 TSval=456950636 TSecr=174618826
src.ip dst.ip AMQP 338 begin attach begin attach
flow
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=520
Ack=482 Win=31360 Len=0 TSval=174618838 TSecr=456950637
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=520
Ack=490 Win=31360 Len=0 TSval=174619828 TSecr=456951037
# Sending a message
dst.ip src.ip AMQP 389 transfer
src.ip dst.ip AMQP 88 disposition
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=843
Ack=512 Win=31360 Len=0 TSval=174620757 TSecr=456951408
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=843
Ack=520 Win=31360 Len=0 TSval=174621757 TSecr=456951808
src.ip dst.ip AMQP 80 close
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=843
Ack=534 Win=31360 Len=0 TSval=174622526 TSecr=456952116
dst.ip src.ip AMQP 87 close
dst.ip src.ip TCP 66 41592 â 5672 [FIN, ACK]
Seq=864 Ack=534 Win=31360 Len=0 TSval=174622526 TSecr=456952116
src.ip dst.ip TCP 66 5672 â 41592 [ACK] Seq=534
Ack=865 Win=261120 Len=0 TSval=456952116 TSecr=174622526
dst.ip src.ip TCP 74 41608 â 5672 [SYN] Seq=0
Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174622526 TSecr=0 WS=128
src.ip dst.ip TCP 74 5672 â 41608 [SYN, ACK]
Seq=0 Ack=1 Win=8192 Len=0 MSS=1460 WS=256 SACK_PERM=1 TSval=456952116
TSecr=174622526
dst.ip src.ip TCP 66 41608 â 5672 [ACK] Seq=1
Ack=1 Win=29312 Len=0 TSval=174622526 TSecr=456952116
dst.ip src.ip AMQP 74 Protocol-Header 1-0-0
src.ip dst.ip TCP 66 5672 â 41592 [FIN, ACK]
Seq=534 Ack=865 Win=261120 Len=0 TSval=456952116 TSecr=174622526
dst.ip src.ip TCP 66 41592 â 5672 [ACK] Seq=865
Ack=535 Win=31360 Len=0 TSval=174622527 TSecr=456952116
src.ip dst.ip TCP 54 5672 â 41608 [RST, ACK]
Seq=1 Ack=9 Win=0 Len=0
dst.ip src.ip TCP 74 41614 â 5672 [SYN] Seq=0
Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174623809 TSecr=0 WS=128
# Stopping the broker
dst.ip src.ip TCP 74 [TCP Retransmission] 41614
â 5672 [SYN] Seq=0 Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174624059
TSecr=0 WS=128
dst.ip src.ip TCP 74 [TCP Retransmission] 41614
â 5672 [SYN] Seq=0 Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174624560
TSecr=0 WS=128
dst.ip src.ip TCP 74 [TCP Retransmission] 41614
â 5672 [SYN] Seq=0 Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174625562
TSecr=0 WS=128
dst.ip src.ip TCP 74 [TCP Retransmission] 41614
â 5672 [SYN] Seq=0 Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174627568
TSecr=0 WS=128
# Restarting the broker
src.ip dst.ip TCP 74 5672 â 41614 [SYN, ACK]
Seq=0 Ack=1 Win=8192 Len=0 MSS=1460 WS=256 SACK_PERM=1 TSval=456954133
TSecr=174627568
dst.ip src.ip TCP 66 41614 â 5672 [ACK] Seq=1
Ack=1 Win=29312 Len=0 TSval=174627568 TSecr=456954133
dst.ip src.ip AMQP 74 Protocol-Header 1-0-0
src.ip dst.ip TCP 66 5672 â 41614 [ACK] Seq=1
Ack=9 Win=262144 Len=0 TSval=456954133 TSecr=174627568
src.ip dst.ip AMQP 102 Protocol-Header 1-0-0
sasl.mechanisms
dst.ip src.ip TCP 66 41614 â 5672 [ACK] Seq=9
Ack=37 Win=29312 Len=0 TSval=174627575 TSecr=456954136
dst.ip src.ip AMQP 117 sasl.init
src.ip dst.ip AMQP 90 sasl.outcome Protocol-Header
1-0-0
dst.ip src.ip AMQP 219 Protocol-Header 1-0-0 open
src.ip dst.ip AMQP 215 open
dst.ip src.ip AMQP 373 begin begin attach attach
src.ip dst.ip AMQP 338 begin begin attach attach
flow
dst.ip src.ip TCP 66 41614 â 5672 [ACK] Seq=520
Ack=482 Win=31360 Len=0 TSval=174627598 TSecr=456954141
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41614 â 5672 [ACK] Seq=520
Ack=490 Win=31360 Len=0 TSval=174628588 TSecr=456954541
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41614 â 5672 [ACK] Seq=520
Ack=498 Win=31360 Len=0 TSval=174629588 TSecr=456954941
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41614 â 5672 [ACK] Seq=520
Ack=506 Win=31360 Len=0 TSval=174630588 TSecr=456955341
# No messages transfered to the broker
src.ip = JMS ip
dst.ip = dispatcher ip
# Connecting the dispatcher to the broker
Source Destination Protocol Length Info
src.ip dst.ip TCP 66 51569 â 5672 [SYN] Seq=0
Win=65535 Len=0 MSS=1460 WS=2 SACK_PERM=1
dst.ip src.ip TCP 66 5672 â 51569 [SYN, ACK]
Seq=0 Ack=1 Win=29200 Len=0 MSS=1460 SACK_PERM=1 WS=128
src.ip dst.ip TCP 54 51569 â 5672 [ACK] Seq=1
Ack=1 Win=65536 Len=0
src.ip dst.ip AMQP 62 Protocol-Header 1-0-0
dst.ip src.ip TCP 60 5672 â 51569 [ACK] Seq=1
Ack=9 Win=29312 Len=0
dst.ip src.ip AMQP 105 Protocol-Header 1-0-0
sasl.mechanisms
src.ip dst.ip AMQP 91 sasl.init
dst.ip src.ip AMQP 76 sasl.outcome
src.ip dst.ip AMQP 300 Protocol-Header 1-0-0 open
dst.ip src.ip AMQP 185 Protocol-Header 1-0-0 open
# Creating the Session
src.ip dst.ip AMQP 86 begin
dst.ip src.ip AMQP 86 begin
src.ip dst.ip AMQP 86 begin
dst.ip src.ip AMQP 86 begin
# Creating MessageProducer
src.ip dst.ip AMQP 313 attach
dst.ip src.ip AMQP 374 attach flow
# Sending a message (success)
src.ip dst.ip AMQP 404 transfer
dst.ip src.ip AMQP 131 flow disposition
# Closing MessageProducer
src.ip dst.ip AMQP 70 detach
dst.ip src.ip AMQP 78 detach
# Stopping broker
src.ip dst.ip TCP 54 51569 â 5672 [ACK] Seq=981
Ack=690 Win=64846 Len=0
src.ip dst.ip AMQP 62 (empty)
dst.ip src.ip TCP 60 5672 â 51569 [ACK] Seq=690
Ack=989 Win=32512 Len=0
src.ip dst.ip AMQP 62 (empty)
dst.ip src.ip TCP 60 5672 â 51569 [ACK] Seq=690
Ack=997 Win=32512 Len=0
src.ip dst.ip AMQP 62 (empty)
dst.ip src.ip TCP 60 5672 â 51569 [ACK] Seq=971
Ack=1272 Win=33536 Len=0
# Trying to create a MessageProducer and sned a message (failure)
src.ip dst.ip AMQP 314 attach
dst.ip src.ip TCP 60 5672 â 51569 [ACK] Seq=971
Ack=1532 Win=34560 Len=0
dst.ip src.ip AMQP 335 attach
src.ip dst.ip TCP 54 51569 â 5672 [ACK]
Seq=1532 Ack=1252 Win=64284 Len=0
# Restarting broker
# Creating MessageProducer
src.ip dst.ip AMQP 314 attach
dst.ip src.ip AMQP 374 attach flow
# Sending a message (success)
src.ip dst.ip AMQP 407 transfer
dst.ip src.ip AMQP 131 flow disposition
# Closing MessageProducer
src.ip dst.ip AMQP 71 detach
dst.ip src.ip AMQP 78 detach
src.ip dst.ip TCP 54 51569 â 5672 [ACK]
Seq=2162 Ack=1673 Win=65434 Len=0
src.ip dst.ip AMQP 62 (empty)
dst.ip src.ip TCP 60 5672 â 51569 [ACK]
Seq=1673 Ack=2170 Win=36736 Len=0
src.ip dst.ip TCP 54 51569 â 5672 [RST, ACK]
Seq=2170 Ack=1673 Win=0 Len=0
dst.ip = dispatcher ip
src.ip = broker ip
# Connecting the dispatcher to the broker
Source Destination Protocol Length Info
dst.ip src.ip TCP 74 41430 â 5672 [SYN] Seq=0
Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174574969 TSecr=0 WS=128
src.ip dst.ip TCP 74 5672 â 41430 [SYN, ACK]
Seq=0 Ack=1 Win=8192 Len=0 MSS=1460 WS=256 SACK_PERM=1 TSval=456933093
TSecr=174574969
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=1
Ack=1 Win=29312 Len=0 TSval=174574970 TSecr=456933093
dst.ip src.ip AMQP 74 Protocol-Header 1-0-0
src.ip dst.ip TCP 66 5672 â 41430 [ACK] Seq=1
Ack=9 Win=262144 Len=0 TSval=456933094 TSecr=174574970
src.ip dst.ip AMQP 102 Protocol-Header 1-0-0
sasl.mechanisms
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=9
Ack=37 Win=29312 Len=0 TSval=174574983 TSecr=456933099
dst.ip src.ip AMQP 117 sasl.init
src.ip dst.ip AMQP 90 sasl.outcome Protocol-Header
1-0-0
dst.ip src.ip AMQP 219 Protocol-Header 1-0-0 open
src.ip dst.ip AMQP 215 open
dst.ip src.ip AMQP 373 begin begin attach attach
src.ip dst.ip AMQP 338 begin begin attach attach
flow
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=520
Ack=498 Win=31360 Len=0 TSval=174577003 TSecr=456933907
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=520
Ack=506 Win=31360 Len=0 TSval=174578002 TSecr=456934306
# Sending a message
dst.ip src.ip AMQP 390 transfer
src.ip dst.ip AMQP 88 disposition
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=844
Ack=528 Win=31360 Len=0 TSval=174578555 TSecr=456934528
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=844
Ack=560 Win=31360 Len=0 TSval=174582556 TSecr=456936128
src.ip dst.ip AMQP 80 close
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=844
Ack=574 Win=31360 Len=0 TSval=174583168 TSecr=456936373
dst.ip src.ip AMQP 87 close
dst.ip src.ip TCP 66 41430 â 5672 [FIN, ACK]
Seq=865 Ack=574 Win=31360 Len=0 TSval=174583168 TSecr=456936373
src.ip dst.ip TCP 66 5672 â 41430 [ACK] Seq=574
Ack=866 Win=261120 Len=0 TSval=456936373 TSecr=174583168
dst.ip src.ip TCP 74 41460 â 5672 [SYN] Seq=0
Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174583169 TSecr=0 WS=128
src.ip dst.ip TCP 74 5672 â 41460 [SYN, ACK]
Seq=0 Ack=1 Win=8192 Len=0 MSS=1460 WS=256 SACK_PERM=1 TSval=456936373
TSecr=174583169
dst.ip src.ip TCP 66 41460 â 5672 [ACK] Seq=1
Ack=1 Win=29312 Len=0 TSval=174583169 TSecr=456936373
dst.ip src.ip AMQP 74 Protocol-Header 1-0-0
src.ip dst.ip TCP 66 5672 â 41430 [FIN, ACK]
Seq=574 Ack=866 Win=261120 Len=0 TSval=456936376 TSecr=174583168
dst.ip src.ip TCP 66 41430 â 5672 [ACK] Seq=866
Ack=575 Win=31360 Len=0 TSval=174583177 TSecr=456936376
src.ip dst.ip TCP 66 5672 â 41460 [ACK] Seq=1
Ack=9 Win=66560 Len=0 TSval=456936393 TSecr=174583169
src.ip dst.ip TCP 54 5672 â 41460 [RST, ACK]
Seq=1 Ack=9 Win=0 Len=0
dst.ip src.ip TCP 74 41466 â 5672 [SYN] Seq=0
Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174584787 TSecr=0 WS=128
# Stopping the broker
dst.ip src.ip TCP 74 [TCP Retransmission] 41466
â 5672 [SYN] Seq=0 Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174585037
TSecr=0 WS=128
dst.ip src.ip TCP 74 [TCP Retransmission] 41466
â 5672 [SYN] Seq=0 Win=29200 Len=0 MSS=1460 SACK_PERM=1 TSval=174592552
TSecr=0 WS=128
# Restarting the broker
src.ip dst.ip TCP 74 5672 â 41466 [SYN, ACK]
Seq=0 Ack=1 Win=8192 Len=0 MSS=1460 WS=256 SACK_PERM=1 TSval=456940126
TSecr=174592552
dst.ip src.ip TCP 66 41466 â 5672 [ACK] Seq=1
Ack=1 Win=29312 Len=0 TSval=174592552 TSecr=456940126
dst.ip src.ip AMQP 74 Protocol-Header 1-0-0
src.ip dst.ip TCP 66 5672 â 41466 [ACK] Seq=1
Ack=9 Win=262144 Len=0 TSval=456940127 TSecr=174592552
src.ip dst.ip AMQP 102 Protocol-Header 1-0-0
sasl.mechanisms
dst.ip src.ip TCP 66 41466 â 5672 [ACK] Seq=9
Ack=37 Win=29312 Len=0 TSval=174592564 TSecr=456940131
dst.ip src.ip AMQP 117 sasl.init
src.ip dst.ip AMQP 90 sasl.outcome Protocol-Header
1-0-0
dst.ip src.ip AMQP 219 Protocol-Header 1-0-0 open
src.ip dst.ip AMQP 215 open
dst.ip src.ip AMQP 373 begin begin attach attach
src.ip dst.ip AMQP 338 begin begin attach attach
flow
dst.ip src.ip TCP 66 41466 â 5672 [ACK] Seq=520
Ack=482 Win=31360 Len=0 TSval=174592590 TSecr=456940138
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41466 â 5672 [ACK] Seq=520
Ack=490 Win=31360 Len=0 TSval=174593580 TSecr=456940538
# Sending a message with a fresh producer
dst.ip src.ip AMQP 390 transfer
src.ip dst.ip AMQP 88 disposition
dst.ip src.ip TCP 66 41466 â 5672 [ACK] Seq=844
Ack=512 Win=31360 Len=0 TSval=174594530 TSecr=456940917
src.ip dst.ip AMQP 74 (empty)
dst.ip src.ip TCP 66 41466 â 5672 [ACK] Seq=844
Ack=520 Win=31360 Len=0 TSval=174595530 TSecr=456941318
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
