diff options
Diffstat (limited to 'qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfProducer.java')
-rw-r--r-- | qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfProducer.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfProducer.java b/qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfProducer.java index a4b2982275..6172a95c3d 100644 --- a/qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfProducer.java +++ b/qpid/java/tools/src/main/java/org/apache/qpid/tools/PerfProducer.java @@ -65,7 +65,7 @@ public class PerfProducer extends PerfBase int msgSizeRange = 1024; enum MessageType { - BYTE, TEXT, MAP, OBJECT; + BYTES, TEXT, MAP, OBJECT; public static MessageType getType(String s) throws Exception { @@ -73,9 +73,9 @@ public class PerfProducer extends PerfBase { return TEXT; } - else if ("byte".equalsIgnoreCase(s)) + else if ("bytes".equalsIgnoreCase(s)) { - return BYTE; + return BYTES; } /*else if ("map".equalsIgnoreCase(s)) { @@ -92,7 +92,7 @@ public class PerfProducer extends PerfBase } }; - MessageType msgType = MessageType.BYTE; + MessageType msgType = MessageType.BYTES; public PerfProducer() { |