This is an automated email from the ASF dual-hosted git repository. orudyy pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
The following commit(s) were added to refs/heads/main by this push: new df0379f QPID-8556:[Broker-J] Expose virtual host threshold for triggering flow to disk on direct memory utilization df0379f is described below commit df0379f9dc61f021480e30a307f30ccde2182afd 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 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 @@ 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 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 @@ 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