activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r468441 [2/6] - in /incubator/activemq/sandbox/qpid: ./ specs/ src/main/java/org/apache/activemq/amqp/broker/ src/main/java/org/apache/activemq/amqp/command/ src/main/java/org/apache/activemq/amqp/transport/ src/main/java/org/apache/activem...
Date Fri, 27 Oct 2006 16:19:06 GMT
Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class DtxSelectBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxSelectOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class DtxSelectOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class DtxStartBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/DtxStartOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class DtxStartOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class ExchangeDeclareBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeclareOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class ExchangeDeclareOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class ExchangeDeleteBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ExchangeDeleteOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class ExchangeDeleteOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileAckBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileAckBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileAckBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileAckBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileAckBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileCancelBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileCancelOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileCancelOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileConsumeBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileConsumeOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileConsumeOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileDeliverBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileDeliverBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileDeliverBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileDeliverBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileOpenBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileOpenOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileOpenOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FilePublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FilePublishBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FilePublishBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FilePublishBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FilePublishBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileQosBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileQosOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileQosOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileRejectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileRejectBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileRejectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileRejectBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileRejectBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileReturnBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileReturnBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileReturnBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileReturnBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileStageBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileStageBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileStageBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/FileStageBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class FileStageBody extends MethodBody
 { 

Copied: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ProtocolInitiation.java (from r468417, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/ProtocolInitiation.java)
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ProtocolInitiation.java?view=diff&rev=468441&p1=incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/ProtocolInitiation.java&r1=468417&p2=incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ProtocolInitiation.java&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/ProtocolInitiation.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/ProtocolInitiation.java Fri Oct 27 09:18:49 2006
@@ -15,14 +15,12 @@
  * limitations under the License.
  *
  */
-package org.apache.activemq.amqp.wireformat;
+package org.apache.activemq.amqp.command;
 
 import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
 
-import org.apache.activemq.amqp.command.AMQDataBlock;
-import org.apache.activemq.amqp.command.Visitor;
 
 import edu.emory.mathcs.backport.java.util.Arrays;
 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueueBindBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueBindOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueueBindOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueueDeclareBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeclareOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueueDeclareOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueueDeleteBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueueDeleteOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueueDeleteOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueuePurgeBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/QueuePurgeOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class QueuePurgeOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamCancelBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamCancelOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamCancelOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamConsumeBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamConsumeOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamConsumeOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamDeliverBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamDeliverBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamDeliverBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamDeliverBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamDeliverBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamPublishBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamPublishBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamPublishBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamPublishBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamPublishBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamQosBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamQosOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamQosOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamReturnBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamReturnBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamReturnBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/StreamReturnBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class StreamReturnBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestContentBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestContentOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestContentOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestIntegerBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestIntegerOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestIntegerOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestStringBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestStringOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestStringOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestTableBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TestTableOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TestTableOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TunnelRequestBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TunnelRequestBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TunnelRequestBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TunnelRequestBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TunnelRequestBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TxCommitBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxCommitOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TxCommitOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TxRollbackBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxRollbackOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TxRollbackOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TxSelectBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectOkBody.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectOkBody.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectOkBody.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/TxSelectOkBody.java Fri Oct 27 09:18:49 2006
@@ -18,10 +18,8 @@
     
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.qpid.*;
-
 /**
- * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=8, minor=0)]
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
  */
 public class TxSelectOkBody extends MethodBody
 { 

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/Visitor.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/Visitor.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/Visitor.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/command/Visitor.java Fri Oct 27 09:18:49 2006
@@ -1,6 +1,5 @@
 package org.apache.activemq.amqp.command;
 
-import org.apache.activemq.amqp.wireformat.ProtocolInitiation;
 
 public class Visitor {
 

Copied: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpProxy.java (from r468417, incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/Proxy.java)
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpProxy.java?view=diff&rev=468441&p1=incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/Proxy.java&r1=468417&p2=incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpProxy.java&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/Proxy.java (original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpProxy.java Fri Oct 27 09:18:49 2006
@@ -37,7 +37,7 @@
  * 
  * @author chirino
  */
-public class Proxy {
+public class AmqpProxy {
 	public static void main(String[] args) throws Exception {
 				
 		String bind = "qpid://localhost:5673";
@@ -56,8 +56,8 @@
 		connector.setRemote(new URI(proxy));
 		connector.start();
 		
-		synchronized(Proxy.class) {
-			Proxy.class.wait();
+		synchronized(AmqpProxy.class) {
+			AmqpProxy.class.wait();
 		}
 		
 	}

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpServerTransportFilter.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpServerTransportFilter.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpServerTransportFilter.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpServerTransportFilter.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,51 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.amqp.transport;
+
+import org.apache.activemq.amqp.command.AMQDataBlock;
+import org.apache.activemq.amqp.command.AccessRequestBody;
+import org.apache.activemq.amqp.command.Visitor;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFilter;
+
+/**
+ * This filter should eventually translate the qpid command set to the ActiveMQ command set.
+ *  
+ * @author chirino
+ */
+public class AmqpServerTransportFilter extends TransportFilter {
+
+	public AmqpServerTransportFilter(Transport next) {
+		super(next);
+	}
+
+	public void onCommand(Object command) {
+		AMQDataBlock frame = (AMQDataBlock) command;
+		try {
+			frame.process(new Visitor() {
+				public Object processAccessRequestBody(AccessRequestBody body) throws Exception {
+					// TODO Auto-generated method stub
+					return super.processAccessRequestBody(body);
+				}
+			});
+		} catch (Exception e) {
+		}
+		super.onCommand(command);
+	}
+	
+}

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpTransportFactory.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpTransportFactory.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpTransportFactory.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/transport/AmqpTransportFactory.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,69 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.amqp.transport;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.UnknownHostException;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.net.SocketFactory;
+
+import org.apache.activemq.amqp.wireformat.AmqpWireFormat;
+import org.apache.activemq.transport.MutexTransport;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.tcp.TcpTransport;
+import org.apache.activemq.transport.tcp.TcpTransportFactory;
+import org.apache.activemq.wireformat.WireFormat;
+
+/**
+ * A <a href="http://stomp.codehaus.org/">STOMP</a> transport factory
+ *
+ * @version $Revision: 1.1.1.1 $
+ */
+public class AmqpTransportFactory extends TcpTransportFactory {
+
+    protected String getDefaultWireFormatType() {
+        return "amqp";
+    }
+
+    
+    public Transport configure(Transport transport, WireFormat wf, Map options) throws Exception {
+    	((AmqpWireFormat)wf).setSendProtocolInitiation(true);
+    	((AmqpWireFormat)wf).setWaitForProtocolInitiation(false);    	
+    	transport = compositeConfigure(transport, wf, options);
+        transport = new MutexTransport(transport);
+        // transport = new ResponseCorrelator(transport);
+        return transport;
+    }
+    
+    public Transport serverConfigure(Transport transport, WireFormat wf, HashMap options) throws Exception {
+    	((AmqpWireFormat)wf).setSendProtocolInitiation(false);
+    	((AmqpWireFormat)wf).setWaitForProtocolInitiation(true);    	
+    	transport = compositeConfigure(transport, wf, options);    	
+    	transport = new AmqpServerTransportFilter(transport);
+        transport = new MutexTransport(transport);
+        return transport;
+    }
+
+    protected TcpTransport createTcpTransport(WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation) throws UnknownHostException, IOException {
+    	return super.createTcpTransport(wf, socketFactory, location, localLocation);
+    }
+
+}
\ No newline at end of file

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormat.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormat.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormat.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormat.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,246 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.amqp.wireformat;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.util.HashMap;
+
+import org.apache.activemq.amqp.command.AMQDataBlock;
+import org.apache.activemq.amqp.command.BasicConsumeBody;
+import org.apache.activemq.amqp.command.BasicContentHeaderProperties;
+import org.apache.activemq.amqp.command.CompositeAMQDataBlock;
+import org.apache.activemq.amqp.command.ContentBody;
+import org.apache.activemq.amqp.command.ContentHeaderBody;
+import org.apache.activemq.amqp.command.HeartbeatBody;
+import org.apache.activemq.amqp.command.MethodBody;
+import org.apache.activemq.amqp.command.ProtocolInitiation;
+import org.apache.activemq.amqp.wireformat.v0_80.EncodingUtils;
+import org.apache.activemq.amqp.wireformat.v0_80.MainRegistry;
+import org.apache.activemq.amqp.wireformat.v0_80.MethodBodyMarshaller;
+import org.apache.activemq.util.ByteSequence;
+import org.apache.activemq.wireformat.WireFormat;
+
+/**
+ * Implements marshalling and unmarsalling to talk to Qpid clients.
+ */
+public class AmqpWireFormat implements WireFormat {
+	
+	private int version=8;
+	private int minorVersion=0;
+	
+	private final HashMap methodBodyMarshallers = new HashMap();
+	
+	private boolean sendProtocolInitiation = false;
+	private boolean waitForProtocolInitiation = true;
+
+	public int getVersion() {
+		return version;
+	}
+	public void setVersion(int version) {
+		this.version=version;
+	}
+	
+	public ByteSequence marshal(Object arg0) throws IOException {
+		throw new RuntimeException("Not implemented");
+	}
+	public Object unmarshal(ByteSequence arg0) throws IOException {
+		throw new RuntimeException("Not implemented");
+	}
+
+	public AmqpWireFormat () {
+		MainRegistry.register(methodBodyMarshallers);
+	}
+
+	private MethodBodyMarshaller getAMQMethodBodyMarshaller(int clazz, int method) {
+		return (MethodBodyMarshaller) methodBodyMarshallers.get(new Integer(clazz * 1000 + method));
+	}
+	
+	/////////////////////////////////////////////////////////////////////////
+	//
+	// HANDLE Marhsalling the Frame objects
+	//
+	/////////////////////////////////////////////////////////////////////////
+	public Object unmarshal(DataInputStream buffer) throws IOException {
+		
+		if( waitForProtocolInitiation ) {
+			ProtocolInitiation initiation = new ProtocolInitiation();
+			initiation.unmarshall(buffer);
+			waitForProtocolInitiation=false;
+			return initiation;
+		}
+
+		AMQDataBlock rc=null;
+        final byte type = buffer.readByte();
+        int channel = EncodingUtils.readUnsignedShort(buffer); 
+        final long length = EncodingUtils.readUnsignedInteger(buffer);
+        
+        switch( type ) {
+        case MethodBody.TYPE:        	
+            int clazz = EncodingUtils.readUnsignedShort(buffer);
+            int method = EncodingUtils.readUnsignedShort(buffer);
+            
+        	MethodBodyMarshaller marshaller = getAMQMethodBodyMarshaller(clazz, method);        	
+        	MethodBody methodBody = marshaller.createBody();
+            marshaller.populateFromBuffer(buffer, length, methodBody);
+            methodBody.channel=channel;
+            rc = methodBody;
+            break;
+            
+        case ContentHeaderBody.TYPE:
+        	ContentHeaderBody contentHeaderBody = new ContentHeaderBody();
+        	
+        	contentHeaderBody.channel = channel;
+        	contentHeaderBody.classId = EncodingUtils.readUnsignedShort(buffer);
+        	contentHeaderBody.weight = EncodingUtils.readUnsignedShort(buffer);
+        	contentHeaderBody.bodySize = buffer.readLong();        	
+            
+            if(contentHeaderBody.classId != BasicConsumeBody.CLASS_ID) {
+    			throw new IOException("Unsupport content header class id: " + contentHeaderBody.classId);
+            }
+            
+            contentHeaderBody.properties = new BasicContentHeaderProperties();
+            EncodingUtils.unmarshalContentHeaderProperties(buffer, contentHeaderBody.properties);
+            
+            rc = contentHeaderBody;
+            break;
+        	        	
+        case ContentBody.TYPE:
+        	
+        	ContentBody contentBody = new ContentBody();        	
+            byte[] data = new byte [(int) length];            
+            buffer.readFully(data);
+            
+            contentBody.channel = channel;
+            contentBody.payload = new ByteSequence(data, 0, data.length);
+            rc = contentBody;
+            break;
+            
+        case HeartbeatBody.TYPE:
+        	HeartbeatBody heartbeatBody = new HeartbeatBody();
+            long size = EncodingUtils.readUnsignedInteger(buffer); // No payload
+            
+            if(size > 0)
+            {
+                //allow other implementations to have a payload, but ignore it:
+                buffer.skip((int) size);
+            }
+            heartbeatBody.channel = channel;
+            rc = heartbeatBody;
+            break;
+            
+        default:
+            throw new IOException("Unsupported frame type: " + type);
+        }
+                        
+        byte marker = buffer.readByte();
+        if ((marker & 0xFF) != 0xCE)
+        {
+            throw new IOException("End of frame marker not found. Read " + marker + " size=" + length + " type=" + type);
+        }
+        return rc;
+	}
+
+	
+	public void marshal(Object object, DataOutputStream buffer) throws IOException {
+		
+		if( sendProtocolInitiation ) {
+			
+			ProtocolInitiation initiation = new ProtocolInitiation(getVersion(), getMinorVersion());
+			initiation.marshall(buffer);
+			sendProtocolInitiation=false;
+			
+			if( object instanceof ProtocolInitiation ) {
+				return;
+			}
+		}
+		
+		// The CompositeAMQDataBlock is a bit special... 
+		if( object.getClass() == CompositeAMQDataBlock.class ) {
+			CompositeAMQDataBlock cdb = (CompositeAMQDataBlock)object;
+			AMQDataBlock[] blocks = cdb.getBlocks();
+			for (AMQDataBlock frame : blocks) {
+				marshal(frame, buffer);
+			}
+			return;
+		}
+			
+		AMQDataBlock frame = (AMQDataBlock) object;
+    	byte type = frame.getFrameType();    	
+        buffer.writeByte(type);
+        EncodingUtils.writeUnsignedShort(buffer, frame.channel);
+        
+        switch( type ) {
+        case MethodBody.TYPE:        	
+            MethodBody methodBody = (MethodBody) frame;
+        	MethodBodyMarshaller marshaller = getAMQMethodBodyMarshaller(methodBody.getClazz(), methodBody.getMethod());        	
+            EncodingUtils.writeUnsignedInteger(buffer, marshaller.getSize(methodBody));
+            EncodingUtils.writeUnsignedShort(buffer, methodBody.getClazz());
+            EncodingUtils.writeUnsignedShort(buffer, methodBody.getMethod());
+            marshaller.writeMethodPayload(buffer, methodBody);
+            break;
+        case ContentHeaderBody.TYPE:
+        	ContentHeaderBody contentHeaderBody = (ContentHeaderBody) frame;
+        	
+            EncodingUtils.writeUnsignedInteger(buffer, 2 + 2 + 8 + EncodingUtils.getContentHeaderPropertiesSize(contentHeaderBody.properties) );
+            EncodingUtils.writeUnsignedShort(buffer, contentHeaderBody.classId);
+            EncodingUtils.writeUnsignedShort(buffer, contentHeaderBody.weight);
+            buffer.writeLong(contentHeaderBody.bodySize);
+            EncodingUtils.marshalContentHeaderProperties(buffer, contentHeaderBody.properties);
+        	break;
+        	
+        case ContentBody.TYPE:
+        	ContentBody contentBody = (ContentBody) frame;
+            ByteSequence payload = contentBody.payload;
+            EncodingUtils.writeUnsignedInteger(buffer, payload.length );
+            buffer.write(payload.getData(), payload.getOffset(), payload.getLength());
+            break;
+            
+        case HeartbeatBody.TYPE:
+            EncodingUtils.writeUnsignedInteger(buffer, 0); // No payload
+            break;
+            
+        default:
+            throw new IOException("Unsupported frame type: " + type);
+        	
+        }
+        
+        buffer.writeByte((byte) 0xCE);
+    }
+	public boolean isSendProtocolInitiation() {
+		return sendProtocolInitiation;
+	}
+	public void setSendProtocolInitiation(boolean sendProtocolInitiation) {
+		this.sendProtocolInitiation = sendProtocolInitiation;
+	}
+	public boolean isWaitForProtocolInitiation() {
+		return waitForProtocolInitiation;
+	}
+	public void setWaitForProtocolInitiation(boolean waitForProtocolInitiation) {
+		this.waitForProtocolInitiation = waitForProtocolInitiation;
+	}
+	public int getMinorVersion() {
+		return minorVersion;
+	}
+	public void setMinorVersion(int minorVersion) {
+		this.minorVersion = minorVersion;
+	}
+	
+	
+}

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormatFactory.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormatFactory.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormatFactory.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/AmqpWireFormatFactory.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,30 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.amqp.wireformat;
+
+import org.apache.activemq.wireformat.WireFormat;
+import org.apache.activemq.wireformat.WireFormatFactory;
+
+/**
+ * Creates WireFormat objects that marshalls the <a href="http://stomp.codehaus.org/">Stomp</a> protocol.
+ */
+public class AmqpWireFormatFactory implements WireFormatFactory {
+    public WireFormat createWireFormat() {
+        return new AmqpWireFormat();
+    }
+}

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,84 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class AccessRequestBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 30; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new AccessRequestBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        AccessRequestBody object = (AccessRequestBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.realm)+
+            1 /*exclusive*/+
+            0 /*passive*/+
+            0 /*active*/+
+            0 /*write*/+
+            0 /*read*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        AccessRequestBody object = (AccessRequestBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.realm);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.exclusive, object.passive, object.active, object.write, object.read});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        AccessRequestBody object = (AccessRequestBody)o;
+        object.realm = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.exclusive = bools[0];
+        object.passive = bools[1];
+        object.active = bools[2];
+        object.write = bools[3];
+        object.read = bools[4];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/AccessRequestOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class AccessRequestOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 30; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new AccessRequestOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        AccessRequestOkBody object = (AccessRequestOkBody)o;
+        
+        return
+        2 /*ticket*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        AccessRequestOkBody object = (AccessRequestOkBody)o;
+        EncodingUtils.writeUnsignedShort(buffer, object.ticket);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        AccessRequestOkBody object = (AccessRequestOkBody)o;
+        object.ticket = EncodingUtils.readUnsignedShort(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicAckBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicAckBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicAckBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicAckBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,76 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicAckBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 80; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new BasicAckBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        BasicAckBody object = (BasicAckBody)o;
+        
+        return
+        8 /*deliveryTag*/+
+            1 /*multiple*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        BasicAckBody object = (BasicAckBody)o;
+        buffer.writeLong(object.deliveryTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.multiple});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        BasicAckBody object = (BasicAckBody)o;
+        object.deliveryTag = buffer.readLong();
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.multiple = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,76 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicCancelBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new BasicCancelBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        BasicCancelBody object = (BasicCancelBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)+
+            1 /*nowait*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        BasicCancelBody object = (BasicCancelBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            EncodingUtils.writeBooleans(buffer, new boolean[]{ object.nowait});
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        BasicCancelBody object = (BasicCancelBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        boolean[] bools = EncodingUtils.readBooleans(buffer);object.nowait = bools[0];
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelOkBodyMarshaller.java (added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/BasicCancelOkBodyMarshaller.java Fri Oct 27 09:18:49 2006
@@ -0,0 +1,73 @@
+/**
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+    
+package org.apache.activemq.amqp.wireformat.v0_80;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
+
+/**
+ * This class is autogenerated, do not modify. [From AMQ protocol 0.80 (major=0, minor=80)]
+ */
+public class BasicCancelOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 60; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new BasicCancelOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        BasicCancelOkBody object = (BasicCancelOkBody)o;
+        
+        return
+        EncodingUtils.encodedShortStringLength(object.consumerTag)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        BasicCancelOkBody object = (BasicCancelOkBody)o;
+        EncodingUtils.writeShortStringBytes(buffer, object.consumerTag);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        BasicCancelOkBody object = (BasicCancelOkBody)o;
+        object.consumerTag = EncodingUtils.readShortString(buffer);
+        		 
+    }
+} 



Mime
View raw message