diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-03-11 17:10:03 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-03-11 17:10:03 +0000 |
| commit | 59451f5205c23613d33b9ee2452ea2214ad89cbd (patch) | |
| tree | b25fdb48f61637af170203becd01b03d84e69288 /java/client | |
| parent | 8c4f60ae66e2a811833eb17008a65de5451d93c4 (diff) | |
| download | qpid-python-59451f5205c23613d33b9ee2452ea2214ad89cbd.tar.gz | |
Allow immediate and mandatory defaults to be changed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@752528 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 9012632adf..22f3b97ecf 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -196,13 +196,13 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic * The default value for immediate flag used by producers created by this session is false. That is, a consumer does * not need to be attached to a queue. */ - protected static final boolean DEFAULT_IMMEDIATE = false; + protected static final boolean DEFAULT_IMMEDIATE = Boolean.parseBoolean(System.getProperty("qpid.default_immediate", "false")); /** * The default value for mandatory flag used by producers created by this session is true. That is, server will not * silently drop messages where no queue is connected to the exchange for the message. */ - protected static final boolean DEFAULT_MANDATORY = true; + protected static final boolean DEFAULT_MANDATORY = Boolean.parseBoolean(System.getProperty("qpid.default_mandatory", "true")); /** System property to enable strict AMQP compliance. */ public static final String STRICT_AMQP = "STRICT_AMQP"; |