diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-07-20 20:46:49 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-07-20 20:46:49 +0000 |
| commit | 831edb0cb38965f03507ccb89bf0b2d098382446 (patch) | |
| tree | c4b51bf08d3fbcb5f13adc9849438c7220ce2843 /java/client | |
| parent | 338e7808666ec8f9ca8301ccfe4f86d5dc709f0d (diff) | |
| download | qpid-python-831edb0cb38965f03507ccb89bf0b2d098382446.tar.gz | |
QPID-3358 Added a controller to coordinate tests run on several jvm's on the same host or multiple host machines.
1. The controller registers participants and waits until the desired numbers of producers and consumers join the test.
2. It then coordinates warmup runs between the participants and starts the actual test run.
3. Once the test is done it collects stats and computes averages,max,minetc.. and prints them out.
The collector is designed run by itself, but can be run inline with a producer for simplicity.
Infact by default the producer will run a controller unless -Dext_controller=true is specified.
This is done to ensure that the simple test cases like the per-report script can be run without additional configuration.
The code would need a bit of cleanup later on. The current form was done quite quickly as a POC for an urgent task.
I will be reviewing the code and making improvements over the comming days.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1148935 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedMapMessage.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedMapMessage.java b/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedMapMessage.java index 58f108f1a4..7f735e0722 100644 --- a/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedMapMessage.java +++ b/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedMapMessage.java @@ -110,7 +110,7 @@ public class AMQPEncodedMapMessage extends JMSMapMessage } // for testing - Map<String,Object> getMap() + public Map<String,Object> getMap() { return _map; } |
