Primarily profiling driven changes:

 - added batched writes of commands/controls issued on a session

 - copy fragmented frames and segments rather than trying to decode
   them piecemeal, removed FragmentDecoder

 - added caching for str8 encode/decode

 - compute sizes as we encode by going back and filling in the amount
   of bytes written rather than computing it up front

 - added SYNC option to commands

 - renamed NO_OPTION argument to NONE

 - added a timeout to Client.java

 - removed use of UUID.fromString in BasicMessageProducer_0_10.java


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

1 files changed, 7 insertions, 3 deletions

diff --git a/java/common/Composite.tpl b/java/common/Composite.tpl
index 46a45b0b91..5df1ef44fb 100644
--- a/java/common/Composite.tpl
+++ b/java/common/Composite.tpl
@@ -80,7 +80,7 @@ if pack > 0:
   out("    private $(PACK_TYPES[pack]) packing_flags = 0;\n");
 
 fields = get_fields(type)
-params = get_parameters(fields)
+params = get_parameters(type, fields)
 options = get_options(fields)
 
 for f in fields:
@@ -99,7 +99,7 @@ for f in fields:
   if f.option: continue
   out("        $(f.set)($(f.name));\n")
 
-if options:
+if options or base == "Method":
   out("""
         for (int i=0; i < _options.length; i++) {
             switch (_options[i]) {
@@ -108,7 +108,11 @@ if options:
   for f in options:
     out("            case $(f.option): packing_flags |= $(f.flag_mask(pack)); break;\n")
 
-  out("""            case NO_OPTION: break;
+  if base == "Method":
+    out("""            case SYNC: this.setSync(true); break;
+            case BATCH: this.setBatch(true); break;
+""")
+  out("""            case NONE: break;
             default: throw new IllegalArgumentException("invalid option: " + _options[i]);
             }
         }