Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

JMS Subscriber infinite loop #5536

Open
asfimport opened this issue May 14, 2021 · 2 comments
Open

JMS Subscriber infinite loop #5536

asfimport opened this issue May 14, 2021 · 2 comments

Comments

@asfimport
Copy link
Collaborator

alessiogiovanni.baroni (Bug 65305):
With an up and running but empty queue on ActiveMQ Artemis broker the JMS Subscriber loops indefinitely although I have 1 thread with 1 loop count.

If I enclose the JMS Subscriber within a Runtime Controller with a strictly positive Runtime (seconds) the behaviour doesn't change.

Severity: normal
OS: Linux

@asfimport
Copy link
Collaborator Author

alessiogiovanni.baroni (migrated from Bugzilla):
With a TRACE level there is this message forever:

2021-05-14 13:40:27,330 TRACE o.a.a.a.c.p.c.i.ChannelImpl: RemotingConnectionID=3804381c Writing buffer for channelID=11
2021-05-14 13:40:27,332 TRACE o.a.a.a.c.p.c.i.RemotingConnectionImpl: RemotingConnectionID=3804381c handling packet PACKET(SessionReceiveMessage)[type=75, channelID=11, responseAsync=false, requiresResponse=false, correlationID=-1, packetObject=SessionReceiveMessage, message=ClientMessageImpl[messageID=707152, durable=false, address=Test,userID=null,properties=TypedProperties[_hornetq.forced.delivery.seq=699]], consumerID=0, deliveryCount=0]
2021-05-14 13:40:27,332 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}::There was nothing on the queue, leaving it now:: returning null
2021-05-14 13:40:27,332 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}:: returning null
2021-05-14 13:40:27,332 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}:: receive(500)
2021-05-14 13:40:27,332 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}::receive(500, false)
2021-05-14 13:40:27,832 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}::Returning null
2021-05-14 13:40:27,832 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}:: receive(500) -> null, trying again with receive(0)
2021-05-14 13:40:27,832 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}::receive(0, true)
2021-05-14 13:40:27,833 TRACE o.a.a.a.c.c.i.ClientConsumerImpl: org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl@66e64f6e{consumerContext=ActiveMQConsumerContext{id=0}, queueName=Test}::Forcing delivery
2021-05-14 13:40:27,833 TRACE o.a.a.a.c.p.c.i.ChannelImpl: RemotingConnectionID=3804381c Sending packet nonblocking PACKET(SessionForceConsumerDelivery)[type=78, channelID=11, responseAsync=false, requiresResponse=false, correlationID=-1, packetObject=SessionForceConsumerDelivery, consumerID=0, sequence=700] on channelID=11

@asfimport
Copy link
Collaborator Author

@FSchumacher (migrated from Bugzilla):
Can you provide a minimal test plan to reproduce?

Have you set up a timeout value on the sampler?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant