blob: e9b4447140fb09df191854035819aeb87064497c [file] [log] [blame]
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
package org.apache.qpid.framing.amqp_8_0;
import org.apache.qpid.framing.EncodingUtils;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.framing.FieldTable;
import org.apache.qpid.framing.AMQFrameDecodingException;
import org.apache.qpid.framing.Content;
import org.apache.mina.common.ByteBuffer;
public abstract class AMQMethodBody_8_0 extends org.apache.qpid.framing.AMQMethodBodyImpl
{
public byte getMajor()
{
return 8;
}
public byte getMinor()
{
return 0;
}
public int getSize()
{
return 2 + 2 + getBodySize();
}
public void writePayload(ByteBuffer buffer)
{
EncodingUtils.writeUnsignedShort(buffer, getClazz());
EncodingUtils.writeUnsignedShort(buffer, getMethod());
writeMethodPayload(buffer);
}
protected byte readByte(ByteBuffer buffer)
{
return buffer.get();
}
protected AMQShortString readAMQShortString(ByteBuffer buffer)
{
return EncodingUtils.readAMQShortString(buffer);
}
protected int getSizeOf(AMQShortString string)
{
return EncodingUtils.encodedShortStringLength(string);
}
protected void writeByte(ByteBuffer buffer, byte b)
{
buffer.put(b);
}
protected void writeAMQShortString(ByteBuffer buffer, AMQShortString string)
{
EncodingUtils.writeShortStringBytes(buffer, string);
}
protected int readInt(ByteBuffer buffer)
{
return buffer.getInt();
}
protected void writeInt(ByteBuffer buffer, int i)
{
buffer.putInt(i);
}
protected FieldTable readFieldTable(ByteBuffer buffer) throws AMQFrameDecodingException
{
return EncodingUtils.readFieldTable(buffer);
}
protected int getSizeOf(FieldTable table)
{
return EncodingUtils.encodedFieldTableLength(table); //To change body of created methods use File | Settings | File Templates.
}
protected void writeFieldTable(ByteBuffer buffer, FieldTable table)
{
EncodingUtils.writeFieldTableBytes(buffer, table);
}
protected long readLong(ByteBuffer buffer)
{
return buffer.getLong();
}
protected void writeLong(ByteBuffer buffer, long l)
{
buffer.putLong(l);
}
protected int getSizeOf(byte[] response)
{
return (response == null) ? 4 : response.length + 4;
}
protected void writeBytes(ByteBuffer buffer, byte[] data)
{
EncodingUtils.writeBytes(buffer,data);
}
protected byte[] readBytes(ByteBuffer buffer)
{
return EncodingUtils.readBytes(buffer);
}
protected short readShort(ByteBuffer buffer)
{
return EncodingUtils.readShort(buffer);
}
protected void writeShort(ByteBuffer buffer, short s)
{
EncodingUtils.writeShort(buffer, s);
}
protected Content readContent(ByteBuffer buffer)
{
return null; //To change body of created methods use File | Settings | File Templates.
}
protected int getSizeOf(Content body)
{
return 0; //To change body of created methods use File | Settings | File Templates.
}
protected void writeContent(ByteBuffer buffer, Content body)
{
//To change body of created methods use File | Settings | File Templates.
}
protected byte readBitfield(ByteBuffer buffer)
{
return readByte(buffer); //To change body of created methods use File | Settings | File Templates.
}
protected int readUnsignedShort(ByteBuffer buffer)
{
return buffer.getUnsignedShort(); //To change body of created methods use File | Settings | File Templates.
}
protected void writeBitfield(ByteBuffer buffer, byte bitfield0)
{
buffer.put(bitfield0);
}
protected void writeUnsignedShort(ByteBuffer buffer, int s)
{
EncodingUtils.writeUnsignedShort(buffer, s);
}
protected long readUnsignedInteger(ByteBuffer buffer)
{
return buffer.getUnsignedInt();
}
protected void writeUnsignedInteger(ByteBuffer buffer, long i)
{
EncodingUtils.writeUnsignedInteger(buffer, i);
}
protected short readUnsignedByte(ByteBuffer buffer)
{
return buffer.getUnsigned();
}
protected void writeUnsignedByte(ByteBuffer buffer, short unsignedByte)
{
EncodingUtils.writeUnsignedByte(buffer, unsignedByte);
}
protected long readTimestamp(ByteBuffer buffer)
{
return EncodingUtils.readTimestamp(buffer);
}
protected void writeTimestamp(ByteBuffer buffer, long t)
{
EncodingUtils.writeTimestamp(buffer, t);
}
}