Profiling driven changes:

 - made AMQShortString cache the toString() value

 - added static initializer to IoTransport to disable use of pooled
   byte buffers

 - modified IoSender to permit buffering

 - removed OutputHandler and eliminated intermediate Frame generation
   between Disassembler and Sender<ByteBuffer> (IoSender)

 - made Disassembler take advantage of IoSender's buffering

 - removed Header and Data as distinct protocol events, added Header
   and Body members to MessageTransfer

 - modified Assembler and Disassembler to decode/encode Header and
   Data directly to/from MessageTransfer

 - modified Disassembler to only write data if encoding of headers is
   successful

 - added Strings.toUTF8(String) -> byte[] to do proper UTF-8 encoding
   that is also fast for 7-bit ascii

 - modified JMSTextMessage to use the Strings.toUTF8

 - modified QpidBench to only generate 7-bit ascii when using
   TextMessage


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682887 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 9 deletions

diff --git a/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java b/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
index 9115a72068..377df17277 100644
--- a/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
+++ b/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
@@ -524,7 +524,7 @@ public class QpidBench
         StringBuilder str = new StringBuilder();
         for (int i = 0; i < opts.size; i++)
         {
-            str.append((char) i);
+            str.append((char) (i % 128));
         }
 
         String body = str.toString();
@@ -782,10 +782,8 @@ public class QpidBench
                 dp.setTimestamp(System.currentTimeMillis());
             }
 
-            ssn.messageTransfer("amq.direct", MessageAcceptMode.NONE, MessageAcquireMode.PRE_ACQUIRED);
-            ssn.header(dp, mp);
-            ssn.data(body.slice());
-            ssn.endData();
+            ssn.messageTransfer("amq.direct", MessageAcceptMode.NONE, MessageAcquireMode.PRE_ACQUIRED,
+                                new Header(dp, mp), body.slice());
             count++;
         }
 
@@ -827,10 +825,9 @@ public class QpidBench
                      {
                          ssn.messageTransfer("amq.direct",
                                              MessageAcceptMode.NONE,
-                                             MessageAcquireMode.PRE_ACQUIRED);
-                         ssn.header(dp, mp);
-                         ssn.data(echo);
-                         ssn.endData();
+                                             MessageAcquireMode.PRE_ACQUIRED,
+                                             new Header(dp, mp),
+                                             echo);
                      }
 
                      if (sample)