Hello,
I have installed Java broker version 7.1.5-SNAPSHOT (last commit
4dd26ddd0263fac22d91a0a16c48789592a9ccb2). Using QPID JMS Client
0.40.0 producer I sent valid messages to the exchange. All messages
end up in the queue, as expected.
When the number of messages sent exceed queue count the broker
produces INFO message:
“CHN-1005 : Flow Control Enforced (Queue queue)”
After that the client is able to continue to send all the remaining
messages, the broker settles every single one of the messages sent.
I have tested that the queue receives all the messages sent even if
either the queue count or queue size are smaller than the number of
messages and/or size of all messages sent by the client.
I would expect the client to be stalled/stopped until either the queue
count or queue size decrease below the queueFlowResumeLimit.
Is there any configuration I might be missing?
For broker configuration please see attached flowcontrol_json.txt file.
Regards
Martin
{
"id" : "43689791-83de-4b43-98f5-4b5dbfba77d6",
"name" : "default",
"type" : "BDB",
"context" : {
"queue.defaultMaximumQueueDepthMessages" : "1000",
"queue.defaultMaximumQueueDepthBytes" : "1048576",
"queue.defaultOverflowPolicy" : "RING"
},
"modelVersion" : "7.1",
"storeOverfullSize" : "0",
"exchanges" : [ {
"id" : "241ee1c7-12b7-4418-aa85-ada42b2a39a1",
"name" : "exchange",
"type" : "topic",
"desiredState" : "ACTIVE",
"durable" : true,
"lifetimePolicy" : "PERMANENT",
"durableBindings" : [ {
"arguments" : { },
"destination" : "queue",
"bindingKey" : "#"
} ],
"unroutableMessageBehaviour" : "REJECT",
"lastUpdatedBy" : "admin",
"lastUpdatedTime" : 1563445999866,
"createdBy" : "admin",
"createdTime" : 1563430435569
} ],
"queues" : [ {
"id" : "df0539ae-f442-45f9-9231-0d903513dc09",
"name" : "queue",
"type" : "standard",
"durable" : true,
"context" : {
"queue.queueFlowResumeLimit" : "50"
},
"alertRepeatGap" : 0,
"alertThresholdMessageAge" : 0,
"alertThresholdMessageSize" : 0,
"alertThresholdQueueDepthBytes" : 0,
"alertThresholdQueueDepthMessages" : 0,
"ensureNondestructiveConsumers" : false,
"holdOnPublishEnabled" : false,
"maximumDeliveryAttempts" : 0,
"maximumDistinctGroups" : 0,
"maximumMessageTtl" : 0,
"maximumQueueDepthBytes" : 1024000,
"maximumQueueDepthMessages" : 1000,
"messageDurability" : "DEFAULT",
"minimumMessageTtl" : 0,
"noLocal" : false,
"overflowPolicy" : "PRODUCER_FLOW_CONTROL",
"owner" : null,
"lastUpdatedBy" : "admin",
"lastUpdatedTime" : 1563445999461,
"createdBy" : "admin",
"createdTime" : 1563430435345
} ]
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
