If I understand your description and code correctly, you create 4
consumers (each on their own session) per 'Service Bus subscription',
using 2 connections, each of which are used for 2 different subs. You
then did something on the server side for a single sub and expected
its related 4 consumers to close, but actually consumers for both subs
in use on the connection were closed.
The logs very clearly show (snippets below) Service Bus remotely
initiating closure of all 8 consumers on the connection in quick
succession, for both sub 3 and sub 4 on connection 2 (rather than sub
1 on connection 1 as mentioned in your description). If that isn't
what you expected based on what you did you will need to raise that
with Microsoft, it's again not a client issue but server-initiated
behaviour.
TRACE 2020-12-10 20:20:41,753 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:5] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790524:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:5:1:test2/subscriptions/sub4'
is force detached. Code: consumer(link10371). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00080ab0000028835fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub4, Timestamp:2020-12-10T20:20:41',
info=null}}
TRACE 2020-12-10 20:20:41,759 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:1] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790494:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:1:1:test2/subscriptions/sub3'
is force detached. Code: consumer(link10359). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00050ab0000028775fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub3, Timestamp:2020-12-10T20:20:41',
info=null}}
TRACE 2020-12-10 20:20:41,761 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:2] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790505:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:2:1:test2/subscriptions/sub3'
is force detached. Code: consumer(link10362). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00050ab00000287a5fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub3, Timestamp:2020-12-10T20:20:41',
info=null}}
TRACE 2020-12-10 20:20:41,762 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:6] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790529:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:6:1:test2/subscriptions/sub4'
is force detached. Code: consumer(link10374). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00080ab0000028865fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub4, Timestamp:2020-12-10T20:20:41',
info=null}}
TRACE 2020-12-10 20:20:41,764 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:3] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790510:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:3:1:test2/subscriptions/sub3'
is force detached. Code: consumer(link10365). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00050ab00000287d5fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub3, Timestamp:2020-12-10T20:20:41',
info=null}}
TRACE 2020-12-10 20:20:41,765 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:7] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790534:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:7:1:test2/subscriptions/sub4'
is force detached. Code: consumer(link10377). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00080ab0000028895fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub4, Timestamp:2020-12-10T20:20:41',
info=null}}
TRACE 2020-12-10 20:20:41,766 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:4] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790515:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:4:1:test2/subscriptions/sub3'
is force detached. Code: consumer(link10368). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00050ab0000028805fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub3, Timestamp:2020-12-10T20:20:41',
info=null}}
TRACE 2020-12-10 20:20:41,766 [AmqpProvider
:(2):[amqps://***.servicebus.windows.net:-1]]
org.apache.qpid.jms.provider.amqp.FRAMES: [1943855334:8] RECV:
Detach{handle=0, closed=true,
error=Error{condition=amqp:link:detach-forced, description='The link
'G7:1790539:qpid-jms:receiver:ID:25209b36-d040-48af-a4a1-3e21f090b3d0:1:8:1:test2/subscriptions/sub4'
is force detached. Code: consumer(link10380). Details:
InnerMessageReceiver was closed.
TrackingId:b77a844b00080ab00000288c5fd2830c_G7_B23,
SystemTracker:***:Topic:test2|sub4, Timestamp:2020-12-10T20:20:41',
info=null}}
On Thu, 10 Dec 2020 at 20:45, akabhishek1
<[email protected]> wrote:
>
> Hey Robbie,
>
> Thanks a lot for your suggestion. I am still working on exception listener,
> will let you know for any issue.
>
> While testing with 0.56.0-SNAPSHOT, I found one distinct issue - consumer
> closed for wrong receiver. Please find below details
>
> JMS Infra details -
> a) JMS Connection - 1
> receiver endpoint - 2
> Consumer on every receiver - 4 (Total 8)
> Separate session for every consumer - Total 8
> b) JMS Connection - 1
> receiver endpoint - 2
> Consumer on every receiver - 4 (Total 8)
> Separate session for every consumer - Total 8
>
> Steps to reproduce this issue -
> 1. Start attached MultipleConsumerTest.java class
> 2. disable only one receiver endpoint (only one subscription - sub1)
> 3. Wait for connection exception
> 4. We can see that two receivers are failing to consume messages which was
> registered on same JMS connection.
> As we have disabled only one subscription, so consumer should be close for
> only one receiver instead of two.
>
> Please find attached sample test class MultipleConsumerTest.java
> <http://qpid.2158936.n2.nabble.com/file/t396358/MultipleConsumerTest.java>
> and error log consumer_closed_for_wrong_receiver.txt
> <http://qpid.2158936.n2.nabble.com/file/t396358/consumer_closed_for_wrong_receiver.txt>
> . Please take a look on this issue and let us know your
> opinion.
>
>
> Regards,
> Abhishek Kumar
>
>
>
>
> --
> Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [email protected]
> For additional commands, e-mail: [email protected]
>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
