You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/10/27 18:19:06 UTC
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...
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;