diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2008-08-22 16:15:02 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2008-08-22 16:15:02 +0000 |
| commit | 87e707234c37276e5b5e51c075d04d35b8e316cc (patch) | |
| tree | 4501a0751dce0d09c4ee4e68851c4dbb252bb172 /qpid/java/client/src | |
| parent | 32b6fe75c94f7d016c9a101e63d179a656d3ea14 (diff) | |
| download | qpid-python-87e707234c37276e5b5e51c075d04d35b8e316cc.tar.gz | |
QPID-1119 : M2x commit : Addition of a System property to AMQProtocolHandler.java to allow the syncWait default to be changed. To perform this a new SlowMessageStore has been added to the systest package. This allows all MessageStore methods to have a pre and/or post delay applied. This delay can be configured dynamically if you have a handle to the Store or via the XML configuration. The SlowMessageStore can also be used to wrap any existing MessageStore (Testing only carried out with the default MemoryMessageStore)
To make testing easier on M2x VMTestCase has been modified to allow the test to simply configure logging levels and systemProperties. These are then reverted after the test has completed.
These changes will naturally need more work to before they are merged to trunk which uses totally different methods for ClientProperties and for running tests.
systests/pom.xml didn't have amqj.logging.level as a systemProperty hence setting it did nothing for the tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@688110 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java index 25439aba94..6e886f25a8 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java @@ -162,7 +162,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter private FailoverException _lastFailoverException; /** Defines the default timeout to use for synchronous protocol commands. */ - private final long DEFAULT_SYNC_TIMEOUT = 1000 * 30; + private final long DEFAULT_SYNC_TIMEOUT = Long.getLong("amqj.default_syncwrite_timeout", 1000 * 30); /** * Creates a new protocol handler, associated with the specified client connection instance. |