diff options
| author | Keith Wall <kwall@apache.org> | 2011-11-28 09:19:15 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2011-11-28 09:19:15 +0000 |
| commit | 4ee4c8776c48bdc0a2bd1c2e34e71bf3a63e33cd (patch) | |
| tree | 8f5a5c8e728615f6442f9e317518817f15a3ee74 /java/common | |
| parent | 907330f70818a437f7a0723743ab98b355d80d67 (diff) | |
| download | qpid-python-4ee4c8776c48bdc0a2bd1c2e34e71bf3a63e33cd.tar.gz | |
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 <keith.wall@gmail.com>, Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207029 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java | 8 | ||||
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/url/BindingURL.java | 9 |
2 files changed, 17 insertions, 0 deletions
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<Boolean> 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 + * <p> + * 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(); |