activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r468441 [6/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
Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringOkBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestStringOkBodyMarshaller.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 TestStringOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestStringOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestStringOkBody object = (TestStringOkBody)o;
+        
+        return
+        4 + (object.result == null ? 0 : object.result.length)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestStringOkBody object = (TestStringOkBody)o;
+        EncodingUtils.writeLongstr(buffer, object.result);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestStringOkBody object = (TestStringOkBody)o;
+        object.result = EncodingUtils.readLongstr(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableBodyMarshaller.java
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,79 @@
+/**
+ *
+ * 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 TestTableBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestTableBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestTableBody object = (TestTableBody)o;
+        
+        return
+        EncodingUtils.encodedFieldTableLength(object.table)+
+            1 /*integerOp*/+
+            1 /*stringOp*/		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestTableBody object = (TestTableBody)o;
+        EncodingUtils.writeFieldTableBytes(buffer, object.table);
+            EncodingUtils.writeUnsignedByte(buffer, object.integerOp);
+            EncodingUtils.writeUnsignedByte(buffer, object.stringOp);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestTableBody object = (TestTableBody)o;
+        object.table = EncodingUtils.readFieldTable(buffer);
+        object.integerOp = EncodingUtils.readUnsignedByte(buffer);
+        object.stringOp = EncodingUtils.readUnsignedByte(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableOkBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TestTableOkBodyMarshaller.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 TestTableOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 120; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TestTableOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TestTableOkBody object = (TestTableOkBody)o;
+        
+        return
+        8 /*integerResult*/+
+            4 + (object.stringResult == null ? 0 : object.stringResult.length)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TestTableOkBody object = (TestTableOkBody)o;
+        buffer.writeLong(object.integerResult);
+            EncodingUtils.writeLongstr(buffer, object.stringResult);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TestTableOkBody object = (TestTableOkBody)o;
+        object.integerResult = buffer.readLong();
+        object.stringResult = EncodingUtils.readLongstr(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TunnelRequestBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TunnelRequestBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TunnelRequestBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TunnelRequestBodyMarshaller.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 TunnelRequestBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 110; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TunnelRequestBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TunnelRequestBody object = (TunnelRequestBody)o;
+        
+        return
+        EncodingUtils.encodedFieldTableLength(object.metaData)		 
+        ;
+         
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TunnelRequestBody object = (TunnelRequestBody)o;
+        EncodingUtils.writeFieldTableBytes(buffer, object.metaData);
+            		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TunnelRequestBody object = (TunnelRequestBody)o;
+        object.metaData = EncodingUtils.readFieldTable(buffer);
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitBodyMarshaller.java
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * 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 TxCommitBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 90; 	
+    public static final int METHOD_ID = 20; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TxCommitBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TxCommitBody object = (TxCommitBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TxCommitBody object = (TxCommitBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TxCommitBody object = (TxCommitBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitOkBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxCommitOkBodyMarshaller.java
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * 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 TxCommitOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 90; 	
+    public static final int METHOD_ID = 21; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TxCommitOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TxCommitOkBody object = (TxCommitOkBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TxCommitOkBody object = (TxCommitOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TxCommitOkBody object = (TxCommitOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackBodyMarshaller.java
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * 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 TxRollbackBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 90; 	
+    public static final int METHOD_ID = 30; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TxRollbackBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TxRollbackBody object = (TxRollbackBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TxRollbackBody object = (TxRollbackBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TxRollbackBody object = (TxRollbackBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackOkBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxRollbackOkBodyMarshaller.java
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * 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 TxRollbackOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 90; 	
+    public static final int METHOD_ID = 31; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TxRollbackOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TxRollbackOkBody object = (TxRollbackOkBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TxRollbackOkBody object = (TxRollbackOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TxRollbackOkBody object = (TxRollbackOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectBodyMarshaller.java
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * 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 TxSelectBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 90; 	
+    public static final int METHOD_ID = 10; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TxSelectBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TxSelectBody object = (TxSelectBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TxSelectBody object = (TxSelectBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TxSelectBody object = (TxSelectBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectOkBodyMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectOkBodyMarshaller.java?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectOkBodyMarshaller.java
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/TxSelectOkBodyMarshaller.java
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,67 @@
+/**
+ *
+ * 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 TxSelectOkBodyMarshaller extends MethodBodyMarshaller
+{ 
+    public static final int CLASS_ID = 90; 	
+    public static final int METHOD_ID = 11; 	
+
+    protected int getClazz()
+    {
+        return CLASS_ID;
+    }
+   
+    protected int getMethod()
+    {
+        return METHOD_ID;
+    }
+
+	public MethodBody createBody() {
+		return new TxSelectOkBody();
+	}
+
+    protected int getBodySize(MethodBody o)
+    {
+        TxSelectOkBody object = (TxSelectOkBody)o;
+        return 0; 
+    }
+
+    public void writeMethodPayload(DataOutput buffer, MethodBody o) throws IOException
+    {
+        TxSelectOkBody object = (TxSelectOkBody)o;
+        		 
+    }
+
+    public void populateMethodBodyFromBuffer(DataInput buffer, MethodBody o) throws IOException
+    {
+        TxSelectOkBody object = (TxSelectOkBody)o;
+        		 
+    }
+} 

Added: incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/results.out
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/results.out?view=auto&rev=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/results.out
(added)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/activemq/amqp/wireformat/v0_80/results.out
Fri Oct 27 09:18:49 2006
@@ -0,0 +1,91 @@
+<?xml version="1.0" encoding="UTF-8"?> 
+    wrote ConnectionStartBodyMarshaller.java 
+    wrote ConnectionStartOkBodyMarshaller.java 
+    wrote ConnectionSecureBodyMarshaller.java 
+    wrote ConnectionSecureOkBodyMarshaller.java 
+    wrote ConnectionTuneBodyMarshaller.java 
+    wrote ConnectionTuneOkBodyMarshaller.java 
+    wrote ConnectionOpenBodyMarshaller.java 
+    wrote ConnectionOpenOkBodyMarshaller.java 
+    wrote ConnectionRedirectBodyMarshaller.java 
+    wrote ConnectionCloseBodyMarshaller.java 
+    wrote ConnectionCloseOkBodyMarshaller.java 
+    wrote ChannelOpenBodyMarshaller.java 
+    wrote ChannelOpenOkBodyMarshaller.java 
+    wrote ChannelFlowBodyMarshaller.java 
+    wrote ChannelFlowOkBodyMarshaller.java 
+    wrote ChannelAlertBodyMarshaller.java 
+    wrote ChannelCloseBodyMarshaller.java 
+    wrote ChannelCloseOkBodyMarshaller.java 
+    wrote AccessRequestBodyMarshaller.java 
+    wrote AccessRequestOkBodyMarshaller.java 
+    wrote ExchangeDeclareBodyMarshaller.java 
+    wrote ExchangeDeclareOkBodyMarshaller.java 
+    wrote ExchangeDeleteBodyMarshaller.java 
+    wrote ExchangeDeleteOkBodyMarshaller.java 
+    wrote QueueDeclareBodyMarshaller.java 
+    wrote QueueDeclareOkBodyMarshaller.java 
+    wrote QueueBindBodyMarshaller.java 
+    wrote QueueBindOkBodyMarshaller.java 
+    wrote QueuePurgeBodyMarshaller.java 
+    wrote QueuePurgeOkBodyMarshaller.java 
+    wrote QueueDeleteBodyMarshaller.java 
+    wrote QueueDeleteOkBodyMarshaller.java 
+    wrote BasicQosBodyMarshaller.java 
+    wrote BasicQosOkBodyMarshaller.java 
+    wrote BasicConsumeBodyMarshaller.java 
+    wrote BasicConsumeOkBodyMarshaller.java 
+    wrote BasicCancelBodyMarshaller.java 
+    wrote BasicCancelOkBodyMarshaller.java 
+    wrote BasicPublishBodyMarshaller.java 
+    wrote BasicReturnBodyMarshaller.java 
+    wrote BasicDeliverBodyMarshaller.java 
+    wrote BasicGetBodyMarshaller.java 
+    wrote BasicGetOkBodyMarshaller.java 
+    wrote BasicGetEmptyBodyMarshaller.java 
+    wrote BasicAckBodyMarshaller.java 
+    wrote BasicRejectBodyMarshaller.java 
+    wrote BasicRecoverBodyMarshaller.java 
+    wrote FileQosBodyMarshaller.java 
+    wrote FileQosOkBodyMarshaller.java 
+    wrote FileConsumeBodyMarshaller.java 
+    wrote FileConsumeOkBodyMarshaller.java 
+    wrote FileCancelBodyMarshaller.java 
+    wrote FileCancelOkBodyMarshaller.java 
+    wrote FileOpenBodyMarshaller.java 
+    wrote FileOpenOkBodyMarshaller.java 
+    wrote FileStageBodyMarshaller.java 
+    wrote FilePublishBodyMarshaller.java 
+    wrote FileReturnBodyMarshaller.java 
+    wrote FileDeliverBodyMarshaller.java 
+    wrote FileAckBodyMarshaller.java 
+    wrote FileRejectBodyMarshaller.java 
+    wrote StreamQosBodyMarshaller.java 
+    wrote StreamQosOkBodyMarshaller.java 
+    wrote StreamConsumeBodyMarshaller.java 
+    wrote StreamConsumeOkBodyMarshaller.java 
+    wrote StreamCancelBodyMarshaller.java 
+    wrote StreamCancelOkBodyMarshaller.java 
+    wrote StreamPublishBodyMarshaller.java 
+    wrote StreamReturnBodyMarshaller.java 
+    wrote StreamDeliverBodyMarshaller.java 
+    wrote TxSelectBodyMarshaller.java 
+    wrote TxSelectOkBodyMarshaller.java 
+    wrote TxCommitBodyMarshaller.java 
+    wrote TxCommitOkBodyMarshaller.java 
+    wrote TxRollbackBodyMarshaller.java 
+    wrote TxRollbackOkBodyMarshaller.java 
+    wrote DtxSelectBodyMarshaller.java 
+    wrote DtxSelectOkBodyMarshaller.java 
+    wrote DtxStartBodyMarshaller.java 
+    wrote DtxStartOkBodyMarshaller.java 
+    wrote TunnelRequestBodyMarshaller.java 
+    wrote TestIntegerBodyMarshaller.java 
+    wrote TestIntegerOkBodyMarshaller.java 
+    wrote TestStringBodyMarshaller.java 
+    wrote TestStringOkBodyMarshaller.java 
+    wrote TestTableBodyMarshaller.java 
+    wrote TestTableOkBodyMarshaller.java 
+    wrote TestContentBodyMarshaller.java 
+    wrote TestContentOkBodyMarshaller.java 
+    wrote MainRegistry.java
\ No newline at end of file

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/exchange/ManagedExchange.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/exchange/ManagedExchange.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/exchange/ManagedExchange.java
(original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/exchange/ManagedExchange.java
Fri Oct 27 09:18:49 2006
@@ -83,8 +83,7 @@
     @MBeanOperation(name="createBinding",
                          description="create a new binding with this exchange",
                          impact= MBeanOperationInfo.ACTION)
-    void createBinding(@MBeanOperationParameter(name="queue name", description="queue name")
String queueName,
-                       @MBeanOperationParameter(name="binding", description="queue binding")String
binding)
+    void createBinding(String queueName, String binding)
         throws JMException;
 
 }

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/management/ManagedBroker.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/management/ManagedBroker.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/management/ManagedBroker.java
(original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/management/ManagedBroker.java
Fri Oct 27 09:18:49 2006
@@ -44,10 +44,10 @@
      */
     @MBeanOperation(name="createNewExchange", description="Creates a new Exchange",
                          impact= MBeanOperationInfo.ACTION)
-    void createNewExchange(@MBeanOperationParameter(name="name", description="Name of the
new exchange")String name,
-                           @MBeanOperationParameter(name="excahnge type", description="Type
of the exchange")String type,
-                           @MBeanOperationParameter(name="durable", description="true if
the Exchang should be durable")boolean durable,
-                           @MBeanOperationParameter(name="passive", description="true of
the Exchange should be passive")boolean passive)
+    void createNewExchange(String name,
+                           String type,
+                           boolean durable,
+                           boolean passive)
         throws IOException, JMException;
 
     /**
@@ -60,7 +60,7 @@
     @MBeanOperation(name="unregisterExchange",
                          description="Unregisters all the related channels and queuebindings
of this exchange",
                          impact= MBeanOperationInfo.ACTION)
-    void unregisterExchange(@MBeanOperationParameter(name="exchange name", description="Name
of the exchange")String exchange)
+    void unregisterExchange(String exchange)
         throws IOException, JMException;
 
     /**
@@ -74,10 +74,10 @@
      */
     @MBeanOperation(name="createQueue", description="Create a new Queue on the Broker server",
                          impact= MBeanOperationInfo.ACTION)
-    void createQueue(@MBeanOperationParameter(name="queue name", description="Name of the
new queue")String queueName,
-                     @MBeanOperationParameter(name="durable", description="true if the queue
should be durable")boolean durable,
-                     @MBeanOperationParameter(name="owner", description="Owner name")String
owner,
-                     @MBeanOperationParameter(name="autoDelete", description="true if the
queue should be auto delete") boolean autoDelete)
+    void createQueue(String queueName,
+                     boolean durable,
+                     String owner,
+                     boolean autoDelete)
         throws IOException, JMException;
 
     /**
@@ -90,6 +90,6 @@
     @MBeanOperation(name="deleteQueue",
                          description="Unregisters the Queue bindings, removes the subscriptions
and deletes the queue",
                          impact= MBeanOperationInfo.ACTION)
-    void deleteQueue(@MBeanOperationParameter(name="queue name", description="Name of the
queue")String queueName)
+    void deleteQueue(String queueName)
         throws IOException, JMException;
 }

Modified: incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/queue/ManagedQueue.java
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/queue/ManagedQueue.java?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/queue/ManagedQueue.java
(original)
+++ incubator/activemq/sandbox/qpid/src/main/java/org/apache/qpid/server/queue/ManagedQueue.java
Fri Oct 27 09:18:49 2006
@@ -185,8 +185,8 @@
      */
     @MBeanOperation(name="viewMessages",
                          description="shows messages in this queue with given indexes. eg.
from index 1 - 100")
-    TabularData viewMessages(@MBeanOperationParameter(name="from index", description="from
index")int fromIndex,
-                             @MBeanOperationParameter(name="to index", description="to index")int
toIndex)
+    TabularData viewMessages(int fromIndex,
+                             int toIndex)
         throws IOException, JMException;
 
     /**

Copied: incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/amqp
(from r468417, incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/qpid)
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/amqp?view=diff&rev=468441&p1=incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/qpid&r1=468417&p2=incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/amqp&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/qpid
(original)
+++ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/transport/amqp
Fri Oct 27 09:18:49 2006
@@ -1 +1 @@
-class=org.apache.activemq.qpid.transport.QpidTransportFactory
+class=org.apache.activemq.amqp.transport.AmqpTransportFactory

Copied: incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/amqp
(from r468417, incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/qpid)
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/amqp?view=diff&rev=468441&p1=incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/qpid&r1=468417&p2=incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/amqp&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/qpid
(original)
+++ incubator/activemq/sandbox/qpid/src/main/resources/META-INF/services/org/apache/activemq/wireformat/amqp
Fri Oct 27 09:18:49 2006
@@ -1 +1 @@
-class=org.apache.activemq.qpid.wireformat.QpidWireFormatFactory
\ No newline at end of file
+class=org.apache.activemq.amqp.wireformat.AmqpWireFormatFactory
\ No newline at end of file

Modified: incubator/activemq/sandbox/qpid/src/test/resources/activemq.xml
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/src/test/resources/activemq.xml?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/src/test/resources/activemq.xml (original)
+++ incubator/activemq/sandbox/qpid/src/test/resources/activemq.xml Fri Oct 27 09:18:49 2006
@@ -20,12 +20,12 @@
 
   <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
   
-  <!--  Notice that the qpid broker uses a different xmlns -->
-  <broker persistent="false" useJmx="false" xmlns="http://activemq.org/config/qpid/1.0">
+  <!--  Notice that the amqp enabled broker uses a different xmlns -->
+  <broker persistent="false" useJmx="false" xmlns="http://activemq.org/config/amqp/1.0">
     
-    <qpidTransportConnectors>
-      <qpidTransportConnector uri="qpid://localhost:5672"/>
-    </qpidTransportConnectors>
+    <amqpTransportConnectors>
+      <amqpTransportConnector uri="amqp://localhost:5672"/>
+    </amqpTransportConnectors>
 
     
     <!-- Notice that we have to switch back to the original xmlns 

Modified: incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl (original)
+++ incubator/activemq/sandbox/qpid/stylesheets/command-java.xsl Fri Oct 27 09:18:49 2006
@@ -44,9 +44,7 @@
 <xsl:template name="generate-class"> 
     <xsl:param name="f"/>
     <xsl:value-of select="amq:copyright()"/>    
-package org.apache.activemq.qpid.command;
-
-import org.apache.activemq.qpid.*;
+package org.apache.activemq.amqp.command;
 
 /**
  * This class is autogenerated, do not modify. [From <xsl:value-of select="$f/parent::frames/@protocol"/>]

Modified: incubator/activemq/sandbox/qpid/stylesheets/marshaller-java.xsl
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/qpid/stylesheets/marshaller-java.xsl?view=diff&rev=468441&r1=468440&r2=468441
==============================================================================
--- incubator/activemq/sandbox/qpid/stylesheets/marshaller-java.xsl (original)
+++ incubator/activemq/sandbox/qpid/stylesheets/marshaller-java.xsl Fri Oct 27 09:18:49 2006
@@ -47,15 +47,14 @@
 <xsl:template name="generate-class"> 
 <xsl:param name="f"/>
 <xsl:value-of select="amq:copyright()"/>    
-package org.apache.activemq.qpid.wireformat.v<xsl:value-of select="$major"/>_<xsl:value-of
select="$minor"/>;
+package org.apache.activemq.amqp.wireformat.v<xsl:value-of select="$major"/>_<xsl:value-of
select="$minor"/>;
 
 import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
 
-import org.apache.activemq.qpid.*;
-import org.apache.activemq.qpid.command.*;
-import org.apache.activemq.qpid.wireformat.*;
+import org.apache.activemq.amqp.command.*;
+import org.apache.activemq.amqp.wireformat.*;
 
 /**
  * This class is autogenerated, do not modify. [From <xsl:value-of select="$f/parent::frames/@protocol"/>]
@@ -189,7 +188,7 @@
     <xsl:result-document href="{$file}" format="textFormat">
     <xsl:value-of select="amq:copyright()"/>
 <!-- package org.apache.qpid.framing_<xsl:value-of select="$major"/>_<xsl:value-of
select="$minor"/>; -->
-package org.apache.activemq.qpid.wireformat.v<xsl:value-of select="$major"/>_<xsl:value-of
select="$minor"/>;
+package org.apache.activemq.amqp.wireformat.v<xsl:value-of select="$major"/>_<xsl:value-of
select="$minor"/>;
 
 import java.util.Map;
 



Mime
View raw message