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 [16/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/ExchangeDeleteBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ExchangeDeleteBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ExchangeDeleteBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ExchangeDeleteBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,154 @@
+/*
+ *
+ * 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 ExchangeDeleteBodyImpl extends AMQMethodBody_0_91 implements ExchangeDeleteBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new ExchangeDeleteBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 40;
+ public static final int METHOD_ID = 20;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _exchange; // [exchange]
+ private final byte _bitfield0; // [ifUnused, nowait]
+
+ // Constructor
+ public ExchangeDeleteBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _exchange = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public ExchangeDeleteBodyImpl(
+ int ticket,
+ AMQShortString exchange,
+ boolean ifUnused,
+ boolean nowait
+ )
+ {
+ _ticket = ticket;
+ _exchange = exchange;
+ byte bitfield0 = (byte)0;
+ if( ifUnused )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ if( nowait )
+ {
+ 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 boolean getIfUnused()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final boolean getNowait()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 1)) != 0;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 3;
+ size += getSizeOf( _exchange );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ writeAMQShortString( buffer, _exchange );
+ writeBitfield( buffer, _bitfield0 );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchExchangeDelete(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[ExchangeDeleteBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "exchange=" );
+ buf.append( getExchange() );
+ buf.append( ", " );
+ buf.append( "ifUnused=" );
+ buf.append( getIfUnused() );
+ 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_0_91/ExchangeDeleteOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ExchangeDeleteOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ExchangeDeleteOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/ExchangeDeleteOkBodyImpl.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 ExchangeDeleteOkBodyImpl extends AMQMethodBody_0_91 implements ExchangeDeleteOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new ExchangeDeleteOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 40;
+ public static final int METHOD_ID = 21;
+
+ // Fields declared in specification
+
+ // Constructor
+ public ExchangeDeleteOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public ExchangeDeleteOkBodyImpl(
+ )
+ {
+ }
+
+ 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).dispatchExchangeDeleteOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[ExchangeDeleteOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodDispatcher_0_91.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodDispatcher_0_91.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodDispatcher_0_91.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodDispatcher_0_91.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,38 @@
+/*
+ *
+ * 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.framing.*;
+
+public interface MethodDispatcher_0_91
+ extends MethodDispatcher,
+ ServerMethodDispatcher_0_91,
+ ClientMethodDispatcher_0_91
+{
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,877 @@
+/*
+ *
+ * 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.framing.*;
+import org.apache.qpid.protocol.AMQConstant;
+
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+
+import org.apache.qpid.framing.abstraction.ProtocolVersionMethodConverter;
+import org.apache.qpid.codec.MarkableDataInput;
+
+
+public class MethodRegistry_0_91 extends MethodRegistry
+{
+
+ private static final Logger _log = LoggerFactory.getLogger(MethodRegistry.class);
+
+ private ProtocolVersionMethodConverter _protocolVersionConverter = new MethodConverter_0_91();
+
+ private final AMQMethodBodyInstanceFactory[][] _factories = new AMQMethodBodyInstanceFactory[91][];
+
+ public MethodRegistry_0_91()
+ {
+ this(new ProtocolVersion((byte)0,(byte)91));
+ }
+
+ public MethodRegistry_0_91(ProtocolVersion pv)
+ {
+ super(pv);
+
+
+
+ // Register method body instance factories for the Connection class.
+
+ _factories[10] = new AMQMethodBodyInstanceFactory[52];
+
+ _factories[10][10] = ConnectionStartBodyImpl.getFactory();
+ _factories[10][11] = ConnectionStartOkBodyImpl.getFactory();
+ _factories[10][20] = ConnectionSecureBodyImpl.getFactory();
+ _factories[10][21] = ConnectionSecureOkBodyImpl.getFactory();
+ _factories[10][30] = ConnectionTuneBodyImpl.getFactory();
+ _factories[10][31] = ConnectionTuneOkBodyImpl.getFactory();
+ _factories[10][40] = ConnectionOpenBodyImpl.getFactory();
+ _factories[10][41] = ConnectionOpenOkBodyImpl.getFactory();
+ _factories[10][50] = ConnectionCloseBodyImpl.getFactory();
+ _factories[10][51] = ConnectionCloseOkBodyImpl.getFactory();
+
+
+
+ // Register method body instance factories for the Channel class.
+
+ _factories[20] = new AMQMethodBodyInstanceFactory[42];
+
+ _factories[20][10] = ChannelOpenBodyImpl.getFactory();
+ _factories[20][11] = ChannelOpenOkBodyImpl.getFactory();
+ _factories[20][20] = ChannelFlowBodyImpl.getFactory();
+ _factories[20][21] = ChannelFlowOkBodyImpl.getFactory();
+ _factories[20][40] = ChannelCloseBodyImpl.getFactory();
+ _factories[20][41] = ChannelCloseOkBodyImpl.getFactory();
+
+
+
+ // Register method body instance factories for the Exchange class.
+
+ _factories[40] = new AMQMethodBodyInstanceFactory[24];
+
+ _factories[40][10] = ExchangeDeclareBodyImpl.getFactory();
+ _factories[40][11] = ExchangeDeclareOkBodyImpl.getFactory();
+ _factories[40][20] = ExchangeDeleteBodyImpl.getFactory();
+ _factories[40][21] = ExchangeDeleteOkBodyImpl.getFactory();
+ _factories[40][22] = ExchangeBoundBodyImpl.getFactory();
+ _factories[40][23] = ExchangeBoundOkBodyImpl.getFactory();
+
+
+
+ // Register method body instance factories for the Queue class.
+
+ _factories[50] = new AMQMethodBodyInstanceFactory[52];
+
+ _factories[50][10] = QueueDeclareBodyImpl.getFactory();
+ _factories[50][11] = QueueDeclareOkBodyImpl.getFactory();
+ _factories[50][20] = QueueBindBodyImpl.getFactory();
+ _factories[50][21] = QueueBindOkBodyImpl.getFactory();
+ _factories[50][30] = QueuePurgeBodyImpl.getFactory();
+ _factories[50][31] = QueuePurgeOkBodyImpl.getFactory();
+ _factories[50][40] = QueueDeleteBodyImpl.getFactory();
+ _factories[50][41] = QueueDeleteOkBodyImpl.getFactory();
+ _factories[50][50] = QueueUnbindBodyImpl.getFactory();
+ _factories[50][51] = QueueUnbindOkBodyImpl.getFactory();
+
+
+
+ // Register method body instance factories for the Basic class.
+
+ _factories[60] = new AMQMethodBodyInstanceFactory[112];
+
+ _factories[60][10] = BasicQosBodyImpl.getFactory();
+ _factories[60][11] = BasicQosOkBodyImpl.getFactory();
+ _factories[60][20] = BasicConsumeBodyImpl.getFactory();
+ _factories[60][21] = BasicConsumeOkBodyImpl.getFactory();
+ _factories[60][30] = BasicCancelBodyImpl.getFactory();
+ _factories[60][31] = BasicCancelOkBodyImpl.getFactory();
+ _factories[60][40] = BasicPublishBodyImpl.getFactory();
+ _factories[60][50] = BasicReturnBodyImpl.getFactory();
+ _factories[60][60] = BasicDeliverBodyImpl.getFactory();
+ _factories[60][70] = BasicGetBodyImpl.getFactory();
+ _factories[60][71] = BasicGetOkBodyImpl.getFactory();
+ _factories[60][72] = BasicGetEmptyBodyImpl.getFactory();
+ _factories[60][80] = BasicAckBodyImpl.getFactory();
+ _factories[60][90] = BasicRejectBodyImpl.getFactory();
+ _factories[60][100] = BasicRecoverBodyImpl.getFactory();
+ _factories[60][110] = BasicRecoverSyncBodyImpl.getFactory();
+ _factories[60][111] = BasicRecoverSyncOkBodyImpl.getFactory();
+
+
+
+ // Register method body instance factories for the Tx class.
+
+ _factories[90] = new AMQMethodBodyInstanceFactory[32];
+
+ _factories[90][10] = TxSelectBodyImpl.getFactory();
+ _factories[90][11] = TxSelectOkBodyImpl.getFactory();
+ _factories[90][20] = TxCommitBodyImpl.getFactory();
+ _factories[90][21] = TxCommitOkBodyImpl.getFactory();
+ _factories[90][30] = TxRollbackBodyImpl.getFactory();
+ _factories[90][31] = TxRollbackOkBodyImpl.getFactory();
+ }
+
+ public AMQMethodBody convertToBody(MarkableDataInput in, long size)
+ throws AMQFrameDecodingException, IOException
+ {
+ int classId = in.readUnsignedShort();
+ int methodId = in.readUnsignedShort();
+
+ AMQMethodBodyInstanceFactory bodyFactory;
+ try
+ {
+ bodyFactory = _factories[classId][methodId];
+ }
+ catch(NullPointerException e)
+ {
+ throw new AMQFrameDecodingException(AMQConstant.COMMAND_INVALID,
+ "Class " + classId + " unknown in AMQP version 0-91"
+ + " (while trying to decode class " + classId + " method " + methodId + ".");
+ }
+ catch(IndexOutOfBoundsException e)
+ {
+ if(classId >= _factories.length)
+ {
+ throw new AMQFrameDecodingException(AMQConstant.COMMAND_INVALID,
+ "Class " + classId + " unknown in AMQP version 0-91"
+ + " (while trying to decode class " + classId + " method " + methodId + ".");
+
+ }
+ else
+ {
+ throw new AMQFrameDecodingException(AMQConstant.COMMAND_INVALID,
+ "Method " + methodId + " unknown in AMQP version 0-91"
+ + " (while trying to decode class " + classId + " method " + methodId + ".");
+
+ }
+ }
+
+ if (bodyFactory == null)
+ {
+ throw new AMQFrameDecodingException(AMQConstant.COMMAND_INVALID,
+ "Method " + methodId + " unknown in AMQP version 0-91"
+ + " (while trying to decode class " + classId + " method " + methodId + ".");
+ }
+
+ return bodyFactory.newInstance(in, size);
+ }
+
+ public int getMaxClassId()
+ {
+ return 90;
+ }
+
+ public int getMaxMethodId(int classId)
+ {
+ return _factories[classId].length - 1;
+ }
+
+
+
+ public ConnectionStartBody createConnectionStartBody(
+ final short versionMajor,
+ final short versionMinor,
+ final FieldTable serverProperties,
+ final byte[] mechanisms,
+ final byte[] locales
+ )
+ {
+ return new ConnectionStartBodyImpl(
+ versionMajor,
+ versionMinor,
+ serverProperties,
+ mechanisms,
+ locales
+ );
+ }
+
+ public ConnectionStartOkBody createConnectionStartOkBody(
+ final FieldTable clientProperties,
+ final AMQShortString mechanism,
+ final byte[] response,
+ final AMQShortString locale
+ )
+ {
+ return new ConnectionStartOkBodyImpl(
+ clientProperties,
+ mechanism,
+ response,
+ locale
+ );
+ }
+
+ public ConnectionSecureBody createConnectionSecureBody(
+ final byte[] challenge
+ )
+ {
+ return new ConnectionSecureBodyImpl(
+ challenge
+ );
+ }
+
+ public ConnectionSecureOkBody createConnectionSecureOkBody(
+ final byte[] response
+ )
+ {
+ return new ConnectionSecureOkBodyImpl(
+ response
+ );
+ }
+
+ public ConnectionTuneBody createConnectionTuneBody(
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ )
+ {
+ return new ConnectionTuneBodyImpl(
+ channelMax,
+ frameMax,
+ heartbeat
+ );
+ }
+
+ public ConnectionTuneOkBody createConnectionTuneOkBody(
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ )
+ {
+ return new ConnectionTuneOkBodyImpl(
+ channelMax,
+ frameMax,
+ heartbeat
+ );
+ }
+
+ public ConnectionOpenBody createConnectionOpenBody(
+ final AMQShortString virtualHost,
+ final AMQShortString capabilities,
+ final boolean insist
+ )
+ {
+ return new ConnectionOpenBodyImpl(
+ virtualHost,
+ capabilities,
+ insist
+ );
+ }
+
+ public ConnectionOpenOkBody createConnectionOpenOkBody(
+ final AMQShortString knownHosts
+ )
+ {
+ return new ConnectionOpenOkBodyImpl(
+ knownHosts
+ );
+ }
+
+ public ConnectionCloseBody createConnectionCloseBody(
+ final int replyCode,
+ final AMQShortString replyText,
+ final int classId,
+ final int methodId
+ )
+ {
+ return new ConnectionCloseBodyImpl(
+ replyCode,
+ replyText,
+ classId,
+ methodId
+ );
+ }
+
+ public ConnectionCloseOkBody createConnectionCloseOkBody(
+ )
+ {
+ return new ConnectionCloseOkBodyImpl(
+ );
+ }
+
+
+
+
+ public ChannelOpenBody createChannelOpenBody(
+ final AMQShortString outOfBand
+ )
+ {
+ return new ChannelOpenBodyImpl(
+ outOfBand
+ );
+ }
+
+ public ChannelOpenOkBody createChannelOpenOkBody(
+ final byte[] channelId
+ )
+ {
+ return new ChannelOpenOkBodyImpl(
+ channelId
+ );
+ }
+
+ public ChannelFlowBody createChannelFlowBody(
+ final boolean active
+ )
+ {
+ return new ChannelFlowBodyImpl(
+ active
+ );
+ }
+
+ public ChannelFlowOkBody createChannelFlowOkBody(
+ final boolean active
+ )
+ {
+ return new ChannelFlowOkBodyImpl(
+ active
+ );
+ }
+
+ public ChannelCloseBody createChannelCloseBody(
+ final int replyCode,
+ final AMQShortString replyText,
+ final int classId,
+ final int methodId
+ )
+ {
+ return new ChannelCloseBodyImpl(
+ replyCode,
+ replyText,
+ classId,
+ methodId
+ );
+ }
+
+ public ChannelCloseOkBody createChannelCloseOkBody(
+ )
+ {
+ return new ChannelCloseOkBodyImpl(
+ );
+ }
+
+
+
+
+ public ExchangeDeclareBody createExchangeDeclareBody(
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString type,
+ final boolean passive,
+ final boolean durable,
+ final boolean autoDelete,
+ final boolean internal,
+ final boolean nowait,
+ final FieldTable arguments
+ )
+ {
+ return new ExchangeDeclareBodyImpl(
+ ticket,
+ exchange,
+ type,
+ passive,
+ durable,
+ autoDelete,
+ internal,
+ nowait,
+ arguments
+ );
+ }
+
+ public ExchangeDeclareOkBody createExchangeDeclareOkBody(
+ )
+ {
+ return new ExchangeDeclareOkBodyImpl(
+ );
+ }
+
+ public ExchangeDeleteBody createExchangeDeleteBody(
+ final int ticket,
+ final AMQShortString exchange,
+ final boolean ifUnused,
+ final boolean nowait
+ )
+ {
+ return new ExchangeDeleteBodyImpl(
+ ticket,
+ exchange,
+ ifUnused,
+ nowait
+ );
+ }
+
+ public ExchangeDeleteOkBody createExchangeDeleteOkBody(
+ )
+ {
+ return new ExchangeDeleteOkBodyImpl(
+ );
+ }
+
+ public ExchangeBoundBody createExchangeBoundBody(
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final AMQShortString queue
+ )
+ {
+ return new ExchangeBoundBodyImpl(
+ exchange,
+ routingKey,
+ queue
+ );
+ }
+
+ public ExchangeBoundOkBody createExchangeBoundOkBody(
+ final int replyCode,
+ final AMQShortString replyText
+ )
+ {
+ return new ExchangeBoundOkBodyImpl(
+ replyCode,
+ replyText
+ );
+ }
+
+
+
+
+ public QueueDeclareBody createQueueDeclareBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean passive,
+ final boolean durable,
+ final boolean exclusive,
+ final boolean autoDelete,
+ final boolean nowait,
+ final FieldTable arguments
+ )
+ {
+ return new QueueDeclareBodyImpl(
+ ticket,
+ queue,
+ passive,
+ durable,
+ exclusive,
+ autoDelete,
+ nowait,
+ arguments
+ );
+ }
+
+ public QueueDeclareOkBody createQueueDeclareOkBody(
+ final AMQShortString queue,
+ final long messageCount,
+ final long consumerCount
+ )
+ {
+ return new QueueDeclareOkBodyImpl(
+ queue,
+ messageCount,
+ consumerCount
+ );
+ }
+
+ public QueueBindBody createQueueBindBody(
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean nowait,
+ final FieldTable arguments
+ )
+ {
+ return new QueueBindBodyImpl(
+ ticket,
+ queue,
+ exchange,
+ routingKey,
+ nowait,
+ arguments
+ );
+ }
+
+ public QueueBindOkBody createQueueBindOkBody(
+ )
+ {
+ return new QueueBindOkBodyImpl(
+ );
+ }
+
+ public QueuePurgeBody createQueuePurgeBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean nowait
+ )
+ {
+ return new QueuePurgeBodyImpl(
+ ticket,
+ queue,
+ nowait
+ );
+ }
+
+ public QueuePurgeOkBody createQueuePurgeOkBody(
+ final long messageCount
+ )
+ {
+ return new QueuePurgeOkBodyImpl(
+ messageCount
+ );
+ }
+
+ public QueueDeleteBody createQueueDeleteBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean ifUnused,
+ final boolean ifEmpty,
+ final boolean nowait
+ )
+ {
+ return new QueueDeleteBodyImpl(
+ ticket,
+ queue,
+ ifUnused,
+ ifEmpty,
+ nowait
+ );
+ }
+
+ public QueueDeleteOkBody createQueueDeleteOkBody(
+ final long messageCount
+ )
+ {
+ return new QueueDeleteOkBodyImpl(
+ messageCount
+ );
+ }
+
+ public QueueUnbindBody createQueueUnbindBody(
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final FieldTable arguments
+ )
+ {
+ return new QueueUnbindBodyImpl(
+ ticket,
+ queue,
+ exchange,
+ routingKey,
+ arguments
+ );
+ }
+
+ public QueueUnbindOkBody createQueueUnbindOkBody(
+ )
+ {
+ return new QueueUnbindOkBodyImpl(
+ );
+ }
+
+
+
+
+ public BasicQosBody createBasicQosBody(
+ final long prefetchSize,
+ final int prefetchCount,
+ final boolean global
+ )
+ {
+ return new BasicQosBodyImpl(
+ prefetchSize,
+ prefetchCount,
+ global
+ );
+ }
+
+ public BasicQosOkBody createBasicQosOkBody(
+ )
+ {
+ return new BasicQosOkBodyImpl(
+ );
+ }
+
+ public BasicConsumeBody createBasicConsumeBody(
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString consumerTag,
+ final boolean noLocal,
+ final boolean noAck,
+ final boolean exclusive,
+ final boolean nowait,
+ final FieldTable arguments
+ )
+ {
+ return new BasicConsumeBodyImpl(
+ ticket,
+ queue,
+ consumerTag,
+ noLocal,
+ noAck,
+ exclusive,
+ nowait,
+ arguments
+ );
+ }
+
+ public BasicConsumeOkBody createBasicConsumeOkBody(
+ final AMQShortString consumerTag
+ )
+ {
+ return new BasicConsumeOkBodyImpl(
+ consumerTag
+ );
+ }
+
+ public BasicCancelBody createBasicCancelBody(
+ final AMQShortString consumerTag,
+ final boolean nowait
+ )
+ {
+ return new BasicCancelBodyImpl(
+ consumerTag,
+ nowait
+ );
+ }
+
+ public BasicCancelOkBody createBasicCancelOkBody(
+ final AMQShortString consumerTag
+ )
+ {
+ return new BasicCancelOkBodyImpl(
+ consumerTag
+ );
+ }
+
+ public BasicPublishBody createBasicPublishBody(
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean mandatory,
+ final boolean immediate
+ )
+ {
+ return new BasicPublishBodyImpl(
+ ticket,
+ exchange,
+ routingKey,
+ mandatory,
+ immediate
+ );
+ }
+
+ public BasicReturnBody createBasicReturnBody(
+ final int replyCode,
+ final AMQShortString replyText,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ )
+ {
+ return new BasicReturnBodyImpl(
+ replyCode,
+ replyText,
+ exchange,
+ routingKey
+ );
+ }
+
+ public BasicDeliverBody createBasicDeliverBody(
+ final AMQShortString consumerTag,
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ )
+ {
+ return new BasicDeliverBodyImpl(
+ consumerTag,
+ deliveryTag,
+ redelivered,
+ exchange,
+ routingKey
+ );
+ }
+
+ public BasicGetBody createBasicGetBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean noAck
+ )
+ {
+ return new BasicGetBodyImpl(
+ ticket,
+ queue,
+ noAck
+ );
+ }
+
+ public BasicGetOkBody createBasicGetOkBody(
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final long messageCount
+ )
+ {
+ return new BasicGetOkBodyImpl(
+ deliveryTag,
+ redelivered,
+ exchange,
+ routingKey,
+ messageCount
+ );
+ }
+
+ public BasicGetEmptyBody createBasicGetEmptyBody(
+ final AMQShortString clusterId
+ )
+ {
+ return new BasicGetEmptyBodyImpl(
+ clusterId
+ );
+ }
+
+ public BasicAckBody createBasicAckBody(
+ final long deliveryTag,
+ final boolean multiple
+ )
+ {
+ return new BasicAckBodyImpl(
+ deliveryTag,
+ multiple
+ );
+ }
+
+ public BasicRejectBody createBasicRejectBody(
+ final long deliveryTag,
+ final boolean requeue
+ )
+ {
+ return new BasicRejectBodyImpl(
+ deliveryTag,
+ requeue
+ );
+ }
+
+ public BasicRecoverBody createBasicRecoverBody(
+ final boolean requeue
+ )
+ {
+ return new BasicRecoverBodyImpl(
+ requeue
+ );
+ }
+
+ public BasicRecoverSyncBody createBasicRecoverSyncBody(
+ final boolean requeue
+ )
+ {
+ return new BasicRecoverSyncBodyImpl(
+ requeue
+ );
+ }
+
+ public BasicRecoverSyncOkBody createBasicRecoverSyncOkBody(
+ )
+ {
+ return new BasicRecoverSyncOkBodyImpl(
+ );
+ }
+
+
+
+
+ public TxSelectBody createTxSelectBody(
+ )
+ {
+ return new TxSelectBodyImpl(
+ );
+ }
+
+ public TxSelectOkBody createTxSelectOkBody(
+ )
+ {
+ return new TxSelectOkBodyImpl(
+ );
+ }
+
+ public TxCommitBody createTxCommitBody(
+ )
+ {
+ return new TxCommitBodyImpl(
+ );
+ }
+
+ public TxCommitOkBody createTxCommitOkBody(
+ )
+ {
+ return new TxCommitOkBodyImpl(
+ );
+ }
+
+ public TxRollbackBody createTxRollbackBody(
+ )
+ {
+ return new TxRollbackBodyImpl(
+ );
+ }
+
+ public TxRollbackOkBody createTxRollbackOkBody(
+ )
+ {
+ return new TxRollbackOkBodyImpl(
+ );
+ }
+
+
+
+ public ProtocolVersionMethodConverter getProtocolVersionMethodConverter()
+ {
+ return _protocolVersionConverter;
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueBindBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueBindBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueBindBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueBindBodyImpl.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:
+ * 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 QueueBindBodyImpl extends AMQMethodBody_0_91 implements QueueBindBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueBindBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 20;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _queue; // [queue]
+ private final AMQShortString _exchange; // [exchange]
+ private final AMQShortString _routingKey; // [routingKey]
+ private final byte _bitfield0; // [nowait]
+ private final FieldTable _arguments; // [arguments]
+
+ // Constructor
+ public QueueBindBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _queue = readAMQShortString( buffer );
+ _exchange = readAMQShortString( buffer );
+ _routingKey = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ _arguments = readFieldTable( buffer );
+ }
+
+ public QueueBindBodyImpl(
+ int ticket,
+ AMQShortString queue,
+ AMQShortString exchange,
+ AMQShortString routingKey,
+ boolean nowait,
+ FieldTable arguments
+ )
+ {
+ _ticket = ticket;
+ _queue = queue;
+ _exchange = exchange;
+ _routingKey = routingKey;
+ byte bitfield0 = (byte)0;
+ if( nowait )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ _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 getExchange()
+ {
+ return _exchange;
+ }
+ public final AMQShortString getRoutingKey()
+ {
+ return _routingKey;
+ }
+ public final boolean getNowait()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final FieldTable getArguments()
+ {
+ return _arguments;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 3;
+ size += getSizeOf( _queue );
+ size += getSizeOf( _exchange );
+ size += getSizeOf( _routingKey );
+ size += getSizeOf( _arguments );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ writeAMQShortString( buffer, _queue );
+ writeAMQShortString( buffer, _exchange );
+ writeAMQShortString( buffer, _routingKey );
+ writeBitfield( buffer, _bitfield0 );
+ writeFieldTable( buffer, _arguments );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchQueueBind(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueBindBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ buf.append( ", " );
+ buf.append( "exchange=" );
+ buf.append( getExchange() );
+ buf.append( ", " );
+ buf.append( "routingKey=" );
+ buf.append( getRoutingKey() );
+ 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_0_91/QueueBindOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueBindOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueBindOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueBindOkBodyImpl.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 QueueBindOkBodyImpl extends AMQMethodBody_0_91 implements QueueBindOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueBindOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 21;
+
+ // Fields declared in specification
+
+ // Constructor
+ public QueueBindOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public QueueBindOkBodyImpl(
+ )
+ {
+ }
+
+ 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).dispatchQueueBindOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueBindOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeclareBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeclareBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeclareBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeclareBodyImpl.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:
+ * 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 QueueDeclareBodyImpl extends AMQMethodBody_0_91 implements QueueDeclareBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueDeclareBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 10;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _queue; // [queue]
+ private final byte _bitfield0; // [passive, durable, exclusive, autoDelete, nowait]
+ private final FieldTable _arguments; // [arguments]
+
+ // Constructor
+ public QueueDeclareBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _queue = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ _arguments = readFieldTable( buffer );
+ }
+
+ public QueueDeclareBodyImpl(
+ int ticket,
+ AMQShortString queue,
+ boolean passive,
+ boolean durable,
+ boolean exclusive,
+ boolean autoDelete,
+ boolean nowait,
+ FieldTable arguments
+ )
+ {
+ _ticket = ticket;
+ _queue = queue;
+ byte bitfield0 = (byte)0;
+ if( passive )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ if( durable )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 1));
+ }
+
+ if( exclusive )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 2));
+ }
+
+ if( autoDelete )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 3));
+ }
+
+ if( nowait )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 4));
+ }
+
+ _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 boolean getPassive()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final boolean getDurable()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 1)) != 0;
+ }
+ public final boolean getExclusive()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 2)) != 0;
+ }
+ public final boolean getAutoDelete()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 3)) != 0;
+ }
+ public final boolean getNowait()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 4)) != 0;
+ }
+ public final FieldTable getArguments()
+ {
+ return _arguments;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 3;
+ size += getSizeOf( _queue );
+ size += getSizeOf( _arguments );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ writeAMQShortString( buffer, _queue );
+ writeBitfield( buffer, _bitfield0 );
+ writeFieldTable( buffer, _arguments );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchQueueDeclare(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueDeclareBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ buf.append( ", " );
+ buf.append( "passive=" );
+ buf.append( getPassive() );
+ buf.append( ", " );
+ buf.append( "durable=" );
+ buf.append( getDurable() );
+ buf.append( ", " );
+ buf.append( "exclusive=" );
+ buf.append( getExclusive() );
+ buf.append( ", " );
+ buf.append( "autoDelete=" );
+ buf.append( getAutoDelete() );
+ 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_0_91/QueueDeclareOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeclareOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeclareOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeclareOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,136 @@
+/*
+ *
+ * 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 QueueDeclareOkBodyImpl extends AMQMethodBody_0_91 implements QueueDeclareOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueDeclareOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 11;
+
+ // Fields declared in specification
+ private final AMQShortString _queue; // [queue]
+ private final long _messageCount; // [messageCount]
+ private final long _consumerCount; // [consumerCount]
+
+ // Constructor
+ public QueueDeclareOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _queue = readAMQShortString( buffer );
+ _messageCount = readUnsignedInteger( buffer );
+ _consumerCount = readUnsignedInteger( buffer );
+ }
+
+ public QueueDeclareOkBodyImpl(
+ AMQShortString queue,
+ long messageCount,
+ long consumerCount
+ )
+ {
+ _queue = queue;
+ _messageCount = messageCount;
+ _consumerCount = consumerCount;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final AMQShortString getQueue()
+ {
+ return _queue;
+ }
+ public final long getMessageCount()
+ {
+ return _messageCount;
+ }
+ public final long getConsumerCount()
+ {
+ return _consumerCount;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 8;
+ size += getSizeOf( _queue );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeAMQShortString( buffer, _queue );
+ writeUnsignedInteger( buffer, _messageCount );
+ writeUnsignedInteger( buffer, _consumerCount );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchQueueDeclareOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueDeclareOkBodyImpl: ");
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ buf.append( ", " );
+ buf.append( "messageCount=" );
+ buf.append( getMessageCount() );
+ buf.append( ", " );
+ buf.append( "consumerCount=" );
+ buf.append( getConsumerCount() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeleteBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeleteBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeleteBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeleteBodyImpl.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:
+ * 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 QueueDeleteBodyImpl extends AMQMethodBody_0_91 implements QueueDeleteBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueDeleteBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 40;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _queue; // [queue]
+ private final byte _bitfield0; // [ifUnused, ifEmpty, nowait]
+
+ // Constructor
+ public QueueDeleteBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _queue = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public QueueDeleteBodyImpl(
+ int ticket,
+ AMQShortString queue,
+ boolean ifUnused,
+ boolean ifEmpty,
+ boolean nowait
+ )
+ {
+ _ticket = ticket;
+ _queue = queue;
+ byte bitfield0 = (byte)0;
+ if( ifUnused )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 0));
+ }
+
+ if( ifEmpty )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 1));
+ }
+
+ if( nowait )
+ {
+ bitfield0 = (byte) (((int) bitfield0) | (1 << 2));
+ }
+ _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 getIfUnused()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 0)) != 0;
+ }
+ public final boolean getIfEmpty()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 1)) != 0;
+ }
+ public final boolean getNowait()
+ {
+ return (((int)(_bitfield0)) & ( 1 << 2)) != 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_0_91)dispatcher).dispatchQueueDelete(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueDeleteBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ buf.append( ", " );
+ buf.append( "ifUnused=" );
+ buf.append( getIfUnused() );
+ buf.append( ", " );
+ buf.append( "ifEmpty=" );
+ buf.append( getIfEmpty() );
+ 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_0_91/QueueDeleteOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeleteOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeleteOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueDeleteOkBodyImpl.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:
+ * 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 QueueDeleteOkBodyImpl extends AMQMethodBody_0_91 implements QueueDeleteOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueDeleteOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 41;
+
+ // Fields declared in specification
+ private final long _messageCount; // [messageCount]
+
+ // Constructor
+ public QueueDeleteOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _messageCount = readUnsignedInteger( buffer );
+ }
+
+ public QueueDeleteOkBodyImpl(
+ long messageCount
+ )
+ {
+ _messageCount = messageCount;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final long getMessageCount()
+ {
+ return _messageCount;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 4;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedInteger( buffer, _messageCount );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchQueueDeleteOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueDeleteOkBodyImpl: ");
+ 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_0_91/QueuePurgeBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueuePurgeBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueuePurgeBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueuePurgeBodyImpl.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:
+ * 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 QueuePurgeBodyImpl extends AMQMethodBody_0_91 implements QueuePurgeBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueuePurgeBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 30;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _queue; // [queue]
+ private final byte _bitfield0; // [nowait]
+
+ // Constructor
+ public QueuePurgeBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _queue = readAMQShortString( buffer );
+ _bitfield0 = readBitfield( buffer );
+ }
+
+ public QueuePurgeBodyImpl(
+ int ticket,
+ AMQShortString queue,
+ boolean nowait
+ )
+ {
+ _ticket = ticket;
+ _queue = queue;
+ 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 int getTicket()
+ {
+ return _ticket;
+ }
+ public final AMQShortString getQueue()
+ {
+ return _queue;
+ }
+ public final boolean getNowait()
+ {
+ 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_0_91)dispatcher).dispatchQueuePurge(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueuePurgeBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ 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_0_91/QueuePurgeOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueuePurgeOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueuePurgeOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueuePurgeOkBodyImpl.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:
+ * 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 QueuePurgeOkBodyImpl extends AMQMethodBody_0_91 implements QueuePurgeOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueuePurgeOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 31;
+
+ // Fields declared in specification
+ private final long _messageCount; // [messageCount]
+
+ // Constructor
+ public QueuePurgeOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _messageCount = readUnsignedInteger( buffer );
+ }
+
+ public QueuePurgeOkBodyImpl(
+ long messageCount
+ )
+ {
+ _messageCount = messageCount;
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+ public final long getMessageCount()
+ {
+ return _messageCount;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 4;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedInteger( buffer, _messageCount );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchQueuePurgeOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueuePurgeOkBodyImpl: ");
+ 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_0_91/QueueUnbindBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueUnbindBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueUnbindBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/QueueUnbindBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,163 @@
+/*
+ *
+ * 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 QueueUnbindBodyImpl extends AMQMethodBody_0_91 implements QueueUnbindBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new QueueUnbindBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 50;
+ public static final int METHOD_ID = 50;
+
+ // Fields declared in specification
+ private final int _ticket; // [ticket]
+ private final AMQShortString _queue; // [queue]
+ private final AMQShortString _exchange; // [exchange]
+ private final AMQShortString _routingKey; // [routingKey]
+ private final FieldTable _arguments; // [arguments]
+
+ // Constructor
+ public QueueUnbindBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ _ticket = readUnsignedShort( buffer );
+ _queue = readAMQShortString( buffer );
+ _exchange = readAMQShortString( buffer );
+ _routingKey = readAMQShortString( buffer );
+ _arguments = readFieldTable( buffer );
+ }
+
+ public QueueUnbindBodyImpl(
+ int ticket,
+ AMQShortString queue,
+ AMQShortString exchange,
+ AMQShortString routingKey,
+ FieldTable arguments
+ )
+ {
+ _ticket = ticket;
+ _queue = queue;
+ _exchange = exchange;
+ _routingKey = routingKey;
+ _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 getExchange()
+ {
+ return _exchange;
+ }
+ public final AMQShortString getRoutingKey()
+ {
+ return _routingKey;
+ }
+ public final FieldTable getArguments()
+ {
+ return _arguments;
+ }
+
+ protected int getBodySize()
+ {
+ int size = 2;
+ size += getSizeOf( _queue );
+ size += getSizeOf( _exchange );
+ size += getSizeOf( _routingKey );
+ size += getSizeOf( _arguments );
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ writeUnsignedShort( buffer, _ticket );
+ writeAMQShortString( buffer, _queue );
+ writeAMQShortString( buffer, _exchange );
+ writeAMQShortString( buffer, _routingKey );
+ writeFieldTable( buffer, _arguments );
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_0_91)dispatcher).dispatchQueueUnbind(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[QueueUnbindBodyImpl: ");
+ buf.append( "ticket=" );
+ buf.append( getTicket() );
+ buf.append( ", " );
+ buf.append( "queue=" );
+ buf.append( getQueue() );
+ buf.append( ", " );
+ buf.append( "exchange=" );
+ buf.append( getExchange() );
+ buf.append( ", " );
+ buf.append( "routingKey=" );
+ buf.append( getRoutingKey() );
+ buf.append( ", " );
+ buf.append( "arguments=" );
+ buf.append( getArguments() );
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org