QPID-8556:[Broker-J] Expose virtual host threshold for triggering flow to disk on direct memory utilization
diff --git a/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java b/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
index c4c0ff5..ec0d776 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
@@ -1499,6 +1499,12 @@
}
@Override
+ public long getInMemoryMessageThreshold()
+ {
+ return getTargetSize();
+ }
+
+ @Override
public <T extends ConfiguredObject<?>> T getAttainedChildFromAddress(final Class<T> childClass,
final String address)
{
diff --git a/broker-core/src/main/java/org/apache/qpid/server/virtualhost/QueueManagingVirtualHost.java b/broker-core/src/main/java/org/apache/qpid/server/virtualhost/QueueManagingVirtualHost.java
index 4cd276a..690c076 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/virtualhost/QueueManagingVirtualHost.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/virtualhost/QueueManagingVirtualHost.java
@@ -276,6 +276,13 @@
long getInMemoryMessageSize();
@SuppressWarnings("unused")
+ @ManagedStatistic(statisticType = StatisticType.POINT_IN_TIME, units = StatisticUnit.BYTES,
+ label = "In-Memory Message Bytes Threshold",
+ description="A threshold for triggering flow to disk when the size of all messages cached in-memory exceeds the value.",
+ metricName = "in_memory_message_threshold_bytes_total")
+ long getInMemoryMessageThreshold();
+
+ @SuppressWarnings("unused")
@ManagedStatistic(statisticType = StatisticType.CUMULATIVE, units = StatisticUnit.BYTES, label = "Evacuated Message Bytes",
description = "Total Number of Bytes Evacuated from Memory Due to Flow to Disk.")
long getBytesEvacuatedFromMemory();
