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 | 34b8e275d9bf816ee35534981a3b5afbf905651a (patch) | |
| tree | a784c3ae5ae0608a519f332554f1bee5253c9375 /qpid/java/common | |
| parent | 1c1293b15d9a4475c3e8dadf5d67f027bd64001b (diff) | |
| download | qpid-python-34b8e275d9bf816ee35534981a3b5afbf905651a.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@1207029 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java | 8 | ||||
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/url/BindingURL.java | 9 |
2 files changed, 17 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java b/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java index 88e2fb0176..a36e7c214e 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java +++ b/qpid/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/qpid/java/common/src/main/java/org/apache/qpid/url/BindingURL.java b/qpid/java/common/src/main/java/org/apache/qpid/url/BindingURL.java index 9996fff311..0e6c865a16 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/url/BindingURL.java +++ b/qpid/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(); |