You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2013/09/29 19:45:25 UTC
svn commit: r1527366 [17/29] - in /qpid/trunk/qpid/java:
broker-core/src/main/java/org/apache/qpid/server/logging/messages/
common/src/main/java/org/apache/qpid/filter/selector/
common/src/main/java/org/apache/qpid/framing/ common/src/main/java/org/apa...
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueUnbindOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueUnbindOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueUnbindOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueUnbindOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class QueueUnbindOkBodyImpl extends AMQMethodBody_0_91 implements QueueUnbindOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueUnbindOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 51;
+
+ // Fields declared in specification
+
+ // Constructor
+ public QueueUnbindOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public QueueUnbindOkBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchQueueUnbindOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueUnbindOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ServerMethodDispatcher_0_91.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ServerMethodDispatcher_0_91.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ServerMethodDispatcher_0_91.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ServerMethodDispatcher_0_91.java Sun Sep 29 17:45:16 2013
@@ -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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.AMQException;
+import org.apache.qpid.framing.*;
+
+
+public interface ServerMethodDispatcher_0_91 extends ServerMethodDispatcher
+{
+
+ public boolean dispatchBasicAck(BasicAckBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicCancel(BasicCancelBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicConsume(BasicConsumeBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicGet(BasicGetBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicPublish(BasicPublishBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicQos(BasicQosBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicRecover(BasicRecoverBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicRecoverSync(BasicRecoverSyncBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicReject(BasicRejectBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelClose(ChannelCloseBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelCloseOk(ChannelCloseOkBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelFlow(ChannelFlowBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelFlowOk(ChannelFlowOkBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelOpen(ChannelOpenBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionClose(ConnectionCloseBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionCloseOk(ConnectionCloseOkBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionOpen(ConnectionOpenBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionSecureOk(ConnectionSecureOkBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionStartOk(ConnectionStartOkBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionTuneOk(ConnectionTuneOkBody body, int channelId) throws AMQException;
+ public boolean dispatchExchangeBound(ExchangeBoundBody body, int channelId) throws AMQException;
+ public boolean dispatchExchangeDeclare(ExchangeDeclareBody body, int channelId) throws AMQException;
+ public boolean dispatchExchangeDelete(ExchangeDeleteBody body, int channelId) throws AMQException;
+ public boolean dispatchQueueBind(QueueBindBody body, int channelId) throws AMQException;
+ public boolean dispatchQueueDeclare(QueueDeclareBody body, int channelId) throws AMQException;
+ public boolean dispatchQueueDelete(QueueDeleteBody body, int channelId) throws AMQException;
+ public boolean dispatchQueuePurge(QueuePurgeBody body, int channelId) throws AMQException;
+ public boolean dispatchQueueUnbind(QueueUnbindBody body, int channelId) throws AMQException;
+ public boolean dispatchTxCommit(TxCommitBody body, int channelId) throws AMQException;
+ public boolean dispatchTxRollback(TxRollbackBody body, int channelId) throws AMQException;
+ public boolean dispatchTxSelect(TxSelectBody body, int channelId) throws AMQException;
+
+}
\ No newline at end of file
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxCommitBodyImpl extends AMQMethodBody_0_91 implements TxCommitBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxCommitBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 20;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxCommitBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxCommitBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchTxCommit(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxCommitBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxCommitOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxCommitOkBodyImpl extends AMQMethodBody_0_91 implements TxCommitOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxCommitOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 21;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxCommitOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxCommitOkBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchTxCommitOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxCommitOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxRollbackBodyImpl extends AMQMethodBody_0_91 implements TxRollbackBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxRollbackBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 30;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxRollbackBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxRollbackBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchTxRollback(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxRollbackBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxRollbackOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxRollbackOkBodyImpl extends AMQMethodBody_0_91 implements TxRollbackOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxRollbackOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 31;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxRollbackOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxRollbackOkBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchTxRollbackOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxRollbackOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxSelectBodyImpl extends AMQMethodBody_0_91 implements TxSelectBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxSelectBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 10;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxSelectBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxSelectBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchTxSelect(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxSelectBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/TxSelectOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-91
+ */
+
+package org.apache.qpid.framing.amqp_0_91;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxSelectOkBodyImpl extends AMQMethodBody_0_91 implements TxSelectOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxSelectOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 11;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxSelectOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxSelectOkBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchTxSelectOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxSelectOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,181 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class AccessRequestBodyImpl extends AMQMethodBody_8_0 implements AccessRequestBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new AccessRequestBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 30;
+ public static final int METHOD_ID = 10;
+
+ // Fields declared in specification
+ private final AMQShortString _realm; // [realm]
+ private final byte _bitfield0; // [exclusive, passive, active, write, read]
+
+ // Constructor
+ public AccessRequestBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _realm = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public AccessRequestBodyImpl(
+ AMQShortString realm,
+ boolean exclusive,
+ boolean passive,
+ boolean active,
+ boolean write,
+ boolean read
+ )
+ {
+ _realm = realm;
+ byte bitfield0 = (byte)0;
+ if( exclusive )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ if( passive )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 1));
+ }
+
+ if( active )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 2));
+ }
+
+ if( write )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 3));
+ }
+
+ if( read )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 4));
+ }
+ _bitfield0 = bitfield0;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final AMQShortString getRealm()
+ {
+ return _realm;
+ }
+ public final boolean getExclusive()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final boolean getPassive()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 1)) != 0;
+ }
+ public final boolean getActive()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 2)) != 0;
+ }
+ public final boolean getWrite()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 3)) != 0;
+ }
+ public final boolean getRead()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 4)) != 0;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 1;
+ size += getSizeOf( _realm );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeAMQShortString( buffer, _realm );
+ writeBitfield( buffer, _bitfield0 );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchAccessRequest(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[AccessRequestBodyImpl: ");
+ buf.append( "realm=" );
+ buf.append( getRealm() );
+ buf.append( ", " );
+ buf.append( "exclusive=" );
+ buf.append( getExclusive() );
+ buf.append( ", " );
+ buf.append( "passive=" );
+ buf.append( getPassive() );
+ buf.append( ", " );
+ buf.append( "active=" );
+ buf.append( getActive() );
+ buf.append( ", " );
+ buf.append( "write=" );
+ buf.append( getWrite() );
+ buf.append( ", " );
+ buf.append( "read=" );
+ buf.append( getRead() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/AccessRequestOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,111 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class AccessRequestOkBodyImpl extends AMQMethodBody_8_0 implements AccessRequestOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new AccessRequestOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 30;
+ public static final int METHOD_ID = 11;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+
+ // Constructor
+ public AccessRequestOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ }
+
+ public AccessRequestOkBodyImpl(
+ int ticket
+ )
+ {
+ _ticket = ticket;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final int getTicket()
+ {
+ return _ticket;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 2;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchAccessRequestOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[AccessRequestOkBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicAckBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicAckBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicAckBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicAckBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,128 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicAckBodyImpl extends AMQMethodBody_8_0 implements BasicAckBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicAckBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 80;
+
+ // Fields declared in specification
+ private final long _deliveryTag; // [deliveryTag]
+ private final byte _bitfield0; // [multiple]
+
+ // Constructor
+ public BasicAckBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _deliveryTag = readLong( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public BasicAckBodyImpl(
+ long deliveryTag,
+ boolean multiple
+ )
+ {
+ _deliveryTag = deliveryTag;
+ byte bitfield0 = (byte)0;
+ if( multiple )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+ _bitfield0 = bitfield0;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final long getDeliveryTag()
+ {
+ return _deliveryTag;
+ }
+ public final boolean getMultiple()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 9;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeLong( buffer, _deliveryTag );
+ writeBitfield( buffer, _bitfield0 );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicAck(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicAckBodyImpl: ");
+ buf.append( "deliveryTag=" );
+ buf.append( getDeliveryTag() );
+ buf.append( ", " );
+ buf.append( "multiple=" );
+ buf.append( getMultiple() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,129 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicCancelBodyImpl extends AMQMethodBody_8_0 implements BasicCancelBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicCancelBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 30;
+
+ // Fields declared in specification
+ private final AMQShortString _consumerTag; // [consumerTag]
+ private final byte _bitfield0; // [nowait]
+
+ // Constructor
+ public BasicCancelBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _consumerTag = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public BasicCancelBodyImpl(
+ AMQShortString consumerTag,
+ boolean nowait
+ )
+ {
+ _consumerTag = consumerTag;
+ byte bitfield0 = (byte)0;
+ if( nowait )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+ _bitfield0 = bitfield0;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final AMQShortString getConsumerTag()
+ {
+ return _consumerTag;
+ }
+ public final boolean getNowait()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 1;
+ size += getSizeOf( _consumerTag );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeAMQShortString( buffer, _consumerTag );
+ writeBitfield( buffer, _bitfield0 );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicCancel(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicCancelBodyImpl: ");
+ buf.append( "consumerTag=" );
+ buf.append( getConsumerTag() );
+ buf.append( ", " );
+ buf.append( "nowait=" );
+ buf.append( getNowait() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicCancelOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,112 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicCancelOkBodyImpl extends AMQMethodBody_8_0 implements BasicCancelOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicCancelOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 31;
+
+ // Fields declared in specification
+ private final AMQShortString _consumerTag; // [consumerTag]
+
+ // Constructor
+ public BasicCancelOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _consumerTag = readAMQShortString( buffer );
+ }
+
+ public BasicCancelOkBodyImpl(
+ AMQShortString consumerTag
+ )
+ {
+ _consumerTag = consumerTag;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final AMQShortString getConsumerTag()
+ {
+ return _consumerTag;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ size += getSizeOf( _consumerTag );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeAMQShortString( buffer, _consumerTag );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicCancelOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicCancelOkBodyImpl: ");
+ buf.append( "consumerTag=" );
+ buf.append( getConsumerTag() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,207 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicConsumeBodyImpl extends AMQMethodBody_8_0 implements BasicConsumeBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicConsumeBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 20;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _queue; // [queue]
+ private final AMQShortString _consumerTag; // [consumerTag]
+ private final byte _bitfield0; // [noLocal, noAck, exclusive, nowait]
+ private final FieldTable _arguments; // [arguments]
+
+ // Constructor
+ public BasicConsumeBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _queue = readAMQShortString( buffer );
+ _consumerTag = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ _arguments = readFieldTable( buffer );
+ }
+
+ public BasicConsumeBodyImpl(
+ int ticket,
+ AMQShortString queue,
+ AMQShortString consumerTag,
+ boolean noLocal,
+ boolean noAck,
+ boolean exclusive,
+ boolean nowait,
+ FieldTable arguments
+ )
+ {
+ _ticket = ticket;
+ _queue = queue;
+ _consumerTag = consumerTag;
+ byte bitfield0 = (byte)0;
+ if( noLocal )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ if( noAck )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 1));
+ }
+
+ if( exclusive )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 2));
+ }
+
+ if( nowait )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 3));
+ }
+
+ _bitfield0 = bitfield0;
+ _arguments = arguments;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final int getTicket()
+ {
+ return _ticket;
+ }
+ public final AMQShortString getQueue()
+ {
+ return _queue;
+ }
+ public final AMQShortString getConsumerTag()
+ {
+ return _consumerTag;
+ }
+ public final boolean getNoLocal()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final boolean getNoAck()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 1)) != 0;
+ }
+ public final boolean getExclusive()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 2)) != 0;
+ }
+ public final boolean getNowait()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 3)) != 0;
+ }
+ public final FieldTable getArguments()
+ {
+ return _arguments;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 3;
+ size += getSizeOf( _queue );
+ size += getSizeOf( _consumerTag );
+ size += getSizeOf( _arguments );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ writeAMQShortString( buffer, _queue );
+ writeAMQShortString( buffer, _consumerTag );
+ writeBitfield( buffer, _bitfield0 );
+ writeFieldTable( buffer, _arguments );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicConsume(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicConsumeBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ buf.append( ", " );
+ buf.append( "consumerTag=" );
+ buf.append( getConsumerTag() );
+ buf.append( ", " );
+ buf.append( "noLocal=" );
+ buf.append( getNoLocal() );
+ buf.append( ", " );
+ buf.append( "noAck=" );
+ buf.append( getNoAck() );
+ buf.append( ", " );
+ buf.append( "exclusive=" );
+ buf.append( getExclusive() );
+ buf.append( ", " );
+ buf.append( "nowait=" );
+ buf.append( getNowait() );
+ buf.append( ", " );
+ buf.append( "arguments=" );
+ buf.append( getArguments() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicConsumeOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,112 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicConsumeOkBodyImpl extends AMQMethodBody_8_0 implements BasicConsumeOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicConsumeOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 21;
+
+ // Fields declared in specification
+ private final AMQShortString _consumerTag; // [consumerTag]
+
+ // Constructor
+ public BasicConsumeOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _consumerTag = readAMQShortString( buffer );
+ }
+
+ public BasicConsumeOkBodyImpl(
+ AMQShortString consumerTag
+ )
+ {
+ _consumerTag = consumerTag;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final AMQShortString getConsumerTag()
+ {
+ return _consumerTag;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ size += getSizeOf( _consumerTag );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeAMQShortString( buffer, _consumerTag );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicConsumeOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicConsumeOkBodyImpl: ");
+ buf.append( "consumerTag=" );
+ buf.append( getConsumerTag() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicDeliverBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicDeliverBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicDeliverBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicDeliverBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,168 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicDeliverBodyImpl extends AMQMethodBody_8_0 implements BasicDeliverBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicDeliverBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 60;
+
+ // Fields declared in specification
+ private final AMQShortString _consumerTag; // [consumerTag]
+ private final long _deliveryTag; // [deliveryTag]
+ private final byte _bitfield0; // [redelivered]
+ private final AMQShortString _exchange; // [exchange]
+ private final AMQShortString _routingKey; // [routingKey]
+
+ // Constructor
+ public BasicDeliverBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _consumerTag = readAMQShortString( buffer );
+ _deliveryTag = readLong( buffer );
+ _bitfield0 = readBitfield( buffer );
+ _exchange = readAMQShortString( buffer );
+ _routingKey = readAMQShortString( buffer );
+ }
+
+ public BasicDeliverBodyImpl(
+ AMQShortString consumerTag,
+ long deliveryTag,
+ boolean redelivered,
+ AMQShortString exchange,
+ AMQShortString routingKey
+ )
+ {
+ _consumerTag = consumerTag;
+ _deliveryTag = deliveryTag;
+ byte bitfield0 = (byte)0;
+ if( redelivered )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ _bitfield0 = bitfield0;
+ _exchange = exchange;
+ _routingKey = routingKey;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final AMQShortString getConsumerTag()
+ {
+ return _consumerTag;
+ }
+ public final long getDeliveryTag()
+ {
+ return _deliveryTag;
+ }
+ public final boolean getRedelivered()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final AMQShortString getExchange()
+ {
+ return _exchange;
+ }
+ public final AMQShortString getRoutingKey()
+ {
+ return _routingKey;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 9;
+ size += getSizeOf( _consumerTag );
+ size += getSizeOf( _exchange );
+ size += getSizeOf( _routingKey );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeAMQShortString( buffer, _consumerTag );
+ writeLong( buffer, _deliveryTag );
+ writeBitfield( buffer, _bitfield0 );
+ writeAMQShortString( buffer, _exchange );
+ writeAMQShortString( buffer, _routingKey );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicDeliver(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicDeliverBodyImpl: ");
+ buf.append( "consumerTag=" );
+ buf.append( getConsumerTag() );
+ buf.append( ", " );
+ buf.append( "deliveryTag=" );
+ buf.append( getDeliveryTag() );
+ buf.append( ", " );
+ buf.append( "redelivered=" );
+ buf.append( getRedelivered() );
+ buf.append( ", " );
+ buf.append( "exchange=" );
+ buf.append( getExchange() );
+ buf.append( ", " );
+ buf.append( "routingKey=" );
+ buf.append( getRoutingKey() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,141 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicGetBodyImpl extends AMQMethodBody_8_0 implements BasicGetBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicGetBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 70;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _queue; // [queue]
+ private final byte _bitfield0; // [noAck]
+
+ // Constructor
+ public BasicGetBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _queue = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public BasicGetBodyImpl(
+ int ticket,
+ AMQShortString queue,
+ boolean noAck
+ )
+ {
+ _ticket = ticket;
+ _queue = queue;
+ byte bitfield0 = (byte)0;
+ if( noAck )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+ _bitfield0 = bitfield0;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final int getTicket()
+ {
+ return _ticket;
+ }
+ public final AMQShortString getQueue()
+ {
+ return _queue;
+ }
+ public final boolean getNoAck()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 3;
+ size += getSizeOf( _queue );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ writeAMQShortString( buffer, _queue );
+ writeBitfield( buffer, _bitfield0 );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicGet(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicGetBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ buf.append( ", " );
+ buf.append( "noAck=" );
+ buf.append( getNoAck() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetEmptyBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetEmptyBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetEmptyBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetEmptyBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,112 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicGetEmptyBodyImpl extends AMQMethodBody_8_0 implements BasicGetEmptyBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicGetEmptyBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 72;
+
+ // Fields declared in specification
+ private final AMQShortString _clusterId; // [clusterId]
+
+ // Constructor
+ public BasicGetEmptyBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _clusterId = readAMQShortString( buffer );
+ }
+
+ public BasicGetEmptyBodyImpl(
+ AMQShortString clusterId
+ )
+ {
+ _clusterId = clusterId;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final AMQShortString getClusterId()
+ {
+ return _clusterId;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ size += getSizeOf( _clusterId );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeAMQShortString( buffer, _clusterId );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicGetEmpty(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicGetEmptyBodyImpl: ");
+ buf.append( "clusterId=" );
+ buf.append( getClusterId() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicGetOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,167 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicGetOkBodyImpl extends AMQMethodBody_8_0 implements BasicGetOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicGetOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 71;
+
+ // Fields declared in specification
+ private final long _deliveryTag; // [deliveryTag]
+ private final byte _bitfield0; // [redelivered]
+ private final AMQShortString _exchange; // [exchange]
+ private final AMQShortString _routingKey; // [routingKey]
+ private final long _messageCount; // [messageCount]
+
+ // Constructor
+ public BasicGetOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _deliveryTag = readLong( buffer );
+ _bitfield0 = readBitfield( buffer );
+ _exchange = readAMQShortString( buffer );
+ _routingKey = readAMQShortString( buffer );
+ _messageCount = readUnsignedInteger( buffer );
+ }
+
+ public BasicGetOkBodyImpl(
+ long deliveryTag,
+ boolean redelivered,
+ AMQShortString exchange,
+ AMQShortString routingKey,
+ long messageCount
+ )
+ {
+ _deliveryTag = deliveryTag;
+ byte bitfield0 = (byte)0;
+ if( redelivered )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ _bitfield0 = bitfield0;
+ _exchange = exchange;
+ _routingKey = routingKey;
+ _messageCount = messageCount;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final long getDeliveryTag()
+ {
+ return _deliveryTag;
+ }
+ public final boolean getRedelivered()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final AMQShortString getExchange()
+ {
+ return _exchange;
+ }
+ public final AMQShortString getRoutingKey()
+ {
+ return _routingKey;
+ }
+ public final long getMessageCount()
+ {
+ return _messageCount;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 13;
+ size += getSizeOf( _exchange );
+ size += getSizeOf( _routingKey );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeLong( buffer, _deliveryTag );
+ writeBitfield( buffer, _bitfield0 );
+ writeAMQShortString( buffer, _exchange );
+ writeAMQShortString( buffer, _routingKey );
+ writeUnsignedInteger( buffer, _messageCount );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicGetOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicGetOkBodyImpl: ");
+ buf.append( "deliveryTag=" );
+ buf.append( getDeliveryTag() );
+ buf.append( ", " );
+ buf.append( "redelivered=" );
+ buf.append( getRedelivered() );
+ buf.append( ", " );
+ buf.append( "exchange=" );
+ buf.append( getExchange() );
+ buf.append( ", " );
+ buf.append( "routingKey=" );
+ buf.append( getRoutingKey() );
+ buf.append( ", " );
+ buf.append( "messageCount=" );
+ buf.append( getMessageCount() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicPublishBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicPublishBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicPublishBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/BasicPublishBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,167 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class BasicPublishBodyImpl extends AMQMethodBody_8_0 implements BasicPublishBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new BasicPublishBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 60;
+ public static final int METHOD_ID = 40;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _exchange; // [exchange]
+ private final AMQShortString _routingKey; // [routingKey]
+ private final byte _bitfield0; // [mandatory, immediate]
+
+ // Constructor
+ public BasicPublishBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _exchange = readAMQShortString( buffer );
+ _routingKey = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public BasicPublishBodyImpl(
+ int ticket,
+ AMQShortString exchange,
+ AMQShortString routingKey,
+ boolean mandatory,
+ boolean immediate
+ )
+ {
+ _ticket = ticket;
+ _exchange = exchange;
+ _routingKey = routingKey;
+ byte bitfield0 = (byte)0;
+ if( mandatory )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ if( immediate )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 1));
+ }
+ _bitfield0 = bitfield0;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final int getTicket()
+ {
+ return _ticket;
+ }
+ public final AMQShortString getExchange()
+ {
+ return _exchange;
+ }
+ public final AMQShortString getRoutingKey()
+ {
+ return _routingKey;
+ }
+ public final boolean getMandatory()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final boolean getImmediate()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 1)) != 0;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 3;
+ size += getSizeOf( _exchange );
+ size += getSizeOf( _routingKey );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ writeAMQShortString( buffer, _exchange );
+ writeAMQShortString( buffer, _routingKey );
+ writeBitfield( buffer, _bitfield0 );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchBasicPublish(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[BasicPublishBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "exchange=" );
+ buf.append( getExchange() );
+ buf.append( ", " );
+ buf.append( "routingKey=" );
+ buf.append( getRoutingKey() );
+ buf.append( ", " );
+ buf.append( "mandatory=" );
+ buf.append( getMandatory() );
+ buf.append( ", " );
+ buf.append( "immediate=" );
+ buf.append( getImmediate() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org