Ryan Livingston created AMQ-9712:
------------------------------------
Summary: AMQP
Key: AMQ-9712
URL: https://issues.apache.org/jira/browse/AMQ-9712
Project: ActiveMQ Classic
Issue Type: Bug
Components: AMQP
Affects Versions: 5.18.3
Reporter: Ryan Livingston
When using AMQP, the ActiveMQ broker does not seem to be reporting a
_PrefetchSize_ which represents the client's set credit window. The result of
this is that the broker's functionality to detect "slow consumers" becomes
inactive and the triggers to a _SlowConsumerStrategy_ are never called.
Is this the expected behavior and/or a limitation of the AMQP protocol?
_TopicSubscription.add(...)_ will only mark a slow consumer if
_ConsumerInfo.prefetchSize_ > 1{_}.{_}
*An example of the reported PrefetchSize by querying the consumer information
via CLI (in this the case the consumer credit window = 10):*
{code:java}
Connection =
org.apache.activemq:type=Broker,brokerName=localhost,connector=clientConnectors,connectorName=amqp,connectionViewType=clientId,connectionName=ID_7a0a3b25-fb5b-445b-9a54-b7756e0a3d47_1_1
PendingQueueSize = 0
MessageCountAwaitingAcknowledge = 0
PrefetchSize = 0
Active = true
MaximumPendingQueueSize = 5000
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
