[qpid-broker-j] branch 8.0.x updated: QPID-8556:[Broker-J] Expose virtual host threshold for triggering flow to disk on direct memory utilization

[orudyy]

This is an automated email from the ASF dual-hosted git repository.

orudyy pushed a commit to branch 8.0.x
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git


The following commit(s) were added to refs/heads/8.0.x by this push:
     new 33a741b  QPID-8556:[Broker-J] Expose virtual host threshold for 
triggering flow to disk on direct memory utilization
33a741b is described below

commit 33a741bac7b510ba4a3326aaca4a868eaa990e3d
Author: Alex Rudyy <oru...@apache.org>
AuthorDate: Sun Jul 25 18:42:58 2021 +0100

    QPID-8556:[Broker-J] Expose virtual host threshold for triggering flow to 
disk on direct memory utilization
---
 .../org/apache/qpid/server/virtualhost/AbstractVirtualHost.java    | 6 ++++++
 .../apache/qpid/server/virtualhost/QueueManagingVirtualHost.java   | 7 +++++++
 2 files changed, 13 insertions(+)

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 7a6286b..0950909 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
@@ -1484,6 +1484,12 @@ public abstract class AbstractVirtualHost<X extends 
AbstractVirtualHost<X>> exte
     }
 
     @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 2022aa4..48a9373 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
@@ -281,6 +281,13 @@ public interface QueueManagingVirtualHost<X extends 
QueueManagingVirtualHost<X>>
     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();

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org