From 4ee4c8776c48bdc0a2bd1c2e34e71bf3a63e33cd Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Mon, 28 Nov 2011 09:19:15 +0000 Subject: QPID-3642,QPID-3643: Add Dead Letter Queue functionality for 0-8/0-9/0-9-1 paths, fixes isBound methods on FanoutExchange Applied patch from Keith Wall , Andrew MacBean and Oleksandr Rudyy git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207029 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/configuration/ClientProperties.java | 8 ++++++++ java/common/src/main/java/org/apache/qpid/url/BindingURL.java | 9 +++++++++ 2 files changed, 17 insertions(+) (limited to 'java/common') diff --git a/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java b/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java index 88e2fb0176..a36e7c214e 100644 --- a/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java +++ b/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java @@ -108,6 +108,14 @@ public class ClientProperties public static final String QPID_TCP_NODELAY_PROP_NAME = "qpid.tcp_nodelay"; public static final String AMQJ_TCP_NODELAY_PROP_NAME = "amqj.tcp_nodelay"; + /** + * System property to set the reject behaviour. default value will be 'normal' but can be + * changed to 'server' in which case the server decides whether a message should be requeued + * or dead lettered. + * This can be overridden by the more specific settings at connection or binding URL level. + */ + public static final String REJECT_BEHAVIOUR_PROP_NAME = "qpid.reject.behaviour"; + /* public static final QpidProperty IGNORE_SET_CLIENTID_PROP_NAME = QpidProperty.booleanProperty(false,"qpid.ignore_set_client_id","ignore_setclientID"); diff --git a/java/common/src/main/java/org/apache/qpid/url/BindingURL.java b/java/common/src/main/java/org/apache/qpid/url/BindingURL.java index 9996fff311..0e6c865a16 100644 --- a/java/common/src/main/java/org/apache/qpid/url/BindingURL.java +++ b/java/common/src/main/java/org/apache/qpid/url/BindingURL.java @@ -37,6 +37,15 @@ public interface BindingURL public static final String OPTION_ROUTING_KEY = "routingkey"; public static final String OPTION_BINDING_KEY = "bindingkey"; + /** + * This option is only applicable for 0-8/0-9/0-9-1 protocols connection + *

+ * It tells the client to delegate the requeue/DLQ decision to the + * server .If this option is not specified, the messages won't be moved to + * the DLQ (or dropped) when delivery count exceeds the maximum. + */ + public static final String OPTION_REJECT_BEHAVIOUR = "rejectbehaviour"; + String getURL(); -- cgit v1.2.1