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