Author: rgodfrey
Date: Sun Apr 12 09:56:17 2015
New Revision: 1672998
URL: http://svn.apache.org/r1672998
Log:
QPID-6476 : Expose vhost target size so a store can decide to flow messages to
disk in recovery if necessary
Modified:
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java
Modified:
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java?rev=1672998&r1=1672997&r2=1672998&view=diff
==============================================================================
---
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java
(original)
+++
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHostImpl.java
Sun Apr 12 09:56:17 2015
@@ -350,6 +350,12 @@ public class BDBHAReplicaVirtualHostImpl
}
@Override
+ public long getTargetSize()
+ {
+ return 0l;
+ }
+
+ @Override
public long getTotalQueueDepthBytes()
{
return 0l;
Modified:
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java?rev=1672998&r1=1672997&r2=1672998&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java
(original)
+++
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/VirtualHost.java
Sun Apr 12 09:56:17 2015
@@ -179,6 +179,7 @@ public interface VirtualHost<X extends V
String getType();
void setTargetSize(long targetSize);
+ long getTargetSize();
long getTotalQueueDepthBytes();
Modified:
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java?rev=1672998&r1=1672997&r2=1672998&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
(original)
+++
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
Sun Apr 12 09:56:17 2015
@@ -1569,6 +1569,11 @@ public abstract class AbstractVirtualHos
allocateTargetSizeToQueues();
}
+ public long getTargetSize()
+ {
+ return _targetSize.get();
+ }
+
private void allocateTargetSizeToQueues()
{
long targetSize = _targetSize.get();
Modified:
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java?rev=1672998&r1=1672997&r2=1672998&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java
(original)
+++
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/RedirectingVirtualHostImpl.java
Sun Apr 12 09:56:17 2015
@@ -350,6 +350,12 @@ class RedirectingVirtualHostImpl
}
@Override
+ public long getTargetSize()
+ {
+ return 0l;
+ }
+
+ @Override
public long getTotalQueueDepthBytes()
{
return 0l;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
