summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-10-31 13:41:14 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-10-31 13:41:14 +0000
commit9c27d3ada9dd3d2e2ddd21f62c9697816cb72563 (patch)
tree813d0413246dc087d8ad4133ad15563743ab6d9e /qpid/java
parentdb3522d576b5d9cbfb23ba40f3c5ba2b8501429b (diff)
downloadqpid-python-9c27d3ada9dd3d2e2ddd21f62c9697816cb72563.tar.gz
QPID-6204 : [Java Broker] Improve distribution fairness for multi-queue consumers
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1635771 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java4
1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java
index 073740f07c..46fbaac3f2 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java
@@ -57,6 +57,10 @@ public interface Queue<X extends Queue<X>> extends ConfiguredObject<X>
@ManagedContextDefault( name = QUEUE_ESTIMATED_MESSAGE_MEMORY_OVERHEAD)
long DEFAULT_ESTIMATED_MESSAGE_MEMORY_OVERHEAD = 1024l;
+ String MAX_ASYNCHRONOUS_DELIVERIES = "queue.maxAsynchronousDeliveries";
+ @ManagedContextDefault(name = MAX_ASYNCHRONOUS_DELIVERIES )
+ int DEFAULT_MAX_ASYNCHRONOUS_DELIVERIES = 80;
+
@ManagedAttribute
Exchange getAlternateExchange();