You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2017/09/13 18:22:29 UTC
qpid-broker-j git commit: QPID-7914: [Java Broker] Allow queue
Minimum/Maximum Message TTL default to be specified by context variables
Repository: qpid-broker-j
Updated Branches:
refs/heads/master 63912deff -> 29a1d9a2f
QPID-7914: [Java Broker] Allow queue Minimum/Maximum Message TTL default to be specified by context variables
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/29a1d9a2
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/29a1d9a2
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/29a1d9a2
Branch: refs/heads/master
Commit: 29a1d9a2f31aa36c5f9bda4ae79c0df951efaa66
Parents: 63912de
Author: Keith Wall <ke...@gmail.com>
Authored: Wed Sep 13 19:18:53 2017 +0100
Committer: Keith Wall <ke...@gmail.com>
Committed: Wed Sep 13 19:18:53 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/qpid/server/model/Queue.java | 16 ++++++++++++++--
1 file changed, 14 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/29a1d9a2/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java
----------------------------------------------------------------------
diff --git a/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java b/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java
index d0a70d1..e5a6879 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/model/Queue.java
@@ -226,19 +226,31 @@ public interface Queue<X extends Queue<X>> extends ConfiguredObject<X>,
+ "none is explicitly set")
String DEFAULT_MESSAGE_DURABILTY = "DEFAULT";
+ @SuppressWarnings("unused")
+ @ManagedContextDefault( name = "queue.minimumMessageTtl",
+ description = "the value to use for the minimumMessageTtl attribute of a queue where "
+ + "none is explicitly set")
+ long DEFAULT_MINIMUM_MESSAGE_TTL = 0L;
+ @SuppressWarnings("unused")
+ @ManagedContextDefault( name = "queue.maximumMessageTtl",
+ description = "the value to use for the maximumMessageTtl attribute of a queue where "
+ + "none is explicitly set")
+ long DEFAULT_MAXIMUM_MESSAGE_TTL = 0L;
@Override
@ManagedAttribute( defaultValue = "${queue.defaultMessageDurability}" )
MessageDurability getMessageDurability();
@SuppressWarnings("unused")
- @ManagedAttribute(description = "Minimum message time to live (TTL) in ms. Messages arriving with smaller TTL"
+ @ManagedAttribute( defaultValue = "${queue.minimumMessageTtl}",
+ description = "Minimum message time to live (TTL) in ms. Messages arriving with smaller TTL"
+ " values will be overridden by this value")
long getMinimumMessageTtl();
@SuppressWarnings("unused")
- @ManagedAttribute(description = "Maximum message time to live (TTL) in ms. Messages arriving with larger TTL"
+ @ManagedAttribute( defaultValue = "${queue.maximumMessageTtl}",
+ description = "Maximum message time to live (TTL) in ms. Messages arriving with larger TTL"
+ " values (including those with no TTL, which are considered to have a TTL value of"
+ " infinity) will be overridden by this value.")
long getMaximumMessageTtl();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org