summaryrefslogtreecommitdiff
path: root/java/client
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2011-07-20 20:46:49 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2011-07-20 20:46:49 +0000
commit831edb0cb38965f03507ccb89bf0b2d098382446 (patch)
treec4b51bf08d3fbcb5f13adc9849438c7220ce2843 /java/client
parent338e7808666ec8f9ca8301ccfe4f86d5dc709f0d (diff)
downloadqpid-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.java2
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;
}