diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2015-04-12 09:56:17 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2015-04-12 09:56:17 +0000 |
| commit | 0755ea744f67ede3a13b6d65ff25b230148b8e65 (patch) | |
| tree | 6403b43e17f58702c2e88eed85ff6570c91f6ff2 | |
| parent | 10b25e7accce0c9337592c9d36815d0b85379ff9 (diff) | |
| download | qpid-python-0755ea744f67ede3a13b6d65ff25b230148b8e65.tar.gz | |
QPID-6476 : Expose vhost target size so a store can decide to flow messages to disk in recovery if necessary
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672998 13f79535-47bb-0310-9956-ffa450edef68
4 files changed, 18 insertions, 0 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java index 30fff154bb..b1444d0f17 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java @@ -350,6 +350,12 @@ public class BDBHAReplicaVirtualHostImpl extends AbstractConfiguredObject<BDBHAR } @Override + public long getTargetSize() + { + return 0l; + } + + @Override public long getTotalQueueDepthBytes() { return 0l; diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java index 843b300413..22359e72c9 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java @@ -179,6 +179,7 @@ public interface VirtualHost<X extends VirtualHost<X, Q, E>, Q extends Queue<?>, String getType(); void setTargetSize(long targetSize); + long getTargetSize(); long getTotalQueueDepthBytes(); diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java index df941d16bf..ccbee865fb 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java @@ -1569,6 +1569,11 @@ public abstract class AbstractVirtualHost<X extends AbstractVirtualHost<X>> exte allocateTargetSizeToQueues(); } + public long getTargetSize() + { + return _targetSize.get(); + } + private void allocateTargetSizeToQueues() { long targetSize = _targetSize.get(); diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java index 917c2fd9a1..b6ace28dd2 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java @@ -350,6 +350,12 @@ class RedirectingVirtualHostImpl } @Override + public long getTargetSize() + { + return 0l; + } + + @Override public long getTotalQueueDepthBytes() { return 0l; |