From 0755ea744f67ede3a13b6d65ff25b230148b8e65 Mon Sep 17 00:00:00 2001
From: Robert Godfrey <rgodfrey@apache.org>
Date: Sun, 12 Apr 2015 09:56:17 +0000
Subject: 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
---
 .../server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java  | 6 ++++++
 .../src/main/java/org/apache/qpid/server/model/VirtualHost.java     | 1 +
 .../org/apache/qpid/server/virtualhost/AbstractVirtualHost.java     | 5 +++++
 .../qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java     | 6 ++++++
 4 files changed, 18 insertions(+)

(limited to 'qpid/java')

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
@@ -349,6 +349,12 @@ public class BDBHAReplicaVirtualHostImpl extends AbstractConfiguredObject<BDBHAR
 
     }
 
+    @Override
+    public long getTargetSize()
+    {
+        return 0l;
+    }
+
     @Override
     public long getTotalQueueDepthBytes()
     {
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
@@ -349,6 +349,12 @@ class RedirectingVirtualHostImpl
 
     }
 
+    @Override
+    public long getTargetSize()
+    {
+        return 0l;
+    }
+
     @Override
     public long getTotalQueueDepthBytes()
     {
-- 
cgit v1.2.1