http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncBody.java index 7e29589..0fa8ba8 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncBody.java @@ -54,11 +54,13 @@ public class BasicRecoverSyncBody extends AMQMethodBodyImpl implements Encodable _bitfield0 = bitfield0; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return _methodId; @@ -69,22 +71,26 @@ public class BasicRecoverSyncBody extends AMQMethodBodyImpl implements Encodable return (((int)(_bitfield0)) & ( 1 << 0)) != 0; } + @Override protected int getBodySize() { int size = 1; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeBitfield( buffer, _bitfield0 ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchBasicRecoverSync(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[BasicRecoverSyncBodyImpl: ");
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncOkBody.java index f87498d..03dd957 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRecoverSyncOkBody.java @@ -53,31 +53,37 @@ public class BasicRecoverSyncOkBody extends AMQMethodBodyImpl implements Encodab } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return _ownMethodId; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchBasicRecoverSyncOk(this, channelId); } + @Override public String toString() { return "[BasicRecoverSyncOkBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRejectBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRejectBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRejectBody.java index 4db69d1..365ebf4 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRejectBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicRejectBody.java @@ -54,11 +54,13 @@ public class BasicRejectBody extends AMQMethodBodyImpl implements EncodableAMQDa _bitfield0 = bitfield0; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -73,23 +75,27 @@ public class BasicRejectBody extends AMQMethodBodyImpl implements EncodableAMQDa return (((int)(_bitfield0)) & ( 1 << 0)) != 0; } + @Override protected int getBodySize() { int size = 9; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeLong( buffer, _deliveryTag ); writeBitfield( buffer, _bitfield0 ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchBasicReject(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[BasicRejectBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicReturnBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicReturnBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicReturnBody.java index b00bc6e..a9bfc0f 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicReturnBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/BasicReturnBody.java @@ -56,11 +56,13 @@ public class BasicReturnBody extends AMQMethodBodyImpl implements EncodableAMQDa _routingKey = routingKey; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -83,6 +85,7 @@ public class BasicReturnBody extends AMQMethodBodyImpl implements EncodableAMQDa return _routingKey; } + @Override protected int getBodySize() { int size = 2; @@ -92,6 +95,7 @@ public class BasicReturnBody extends AMQMethodBodyImpl implements EncodableAMQDa return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _replyCode ); @@ -100,11 +104,13 @@ public class BasicReturnBody extends AMQMethodBodyImpl implements EncodableAMQDa writeAMQShortString( buffer, _routingKey ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchBasicReturn(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[BasicReturnBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelAlertBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelAlertBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelAlertBody.java index e550d21..91dfc69 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelAlertBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelAlertBody.java @@ -56,11 +56,13 @@ public class ChannelAlertBody extends AMQMethodBodyImpl implements EncodableAMQD _details = details; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -79,6 +81,7 @@ public class ChannelAlertBody extends AMQMethodBodyImpl implements EncodableAMQD return _details; } + @Override protected int getBodySize() { int size = 2; @@ -87,6 +90,7 @@ public class ChannelAlertBody extends AMQMethodBodyImpl implements EncodableAMQD return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _replyCode ); @@ -94,11 +98,13 @@ public class ChannelAlertBody extends AMQMethodBodyImpl implements EncodableAMQD writeFieldTable( buffer, _details ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchChannelAlert(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ChannelAlertBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseBody.java index 120362d..99ffb1e 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseBody.java @@ -56,11 +56,13 @@ public class ChannelCloseBody extends AMQMethodBodyImpl implements EncodableAMQD _methodId = methodId; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -83,6 +85,7 @@ public class ChannelCloseBody extends AMQMethodBodyImpl implements EncodableAMQD return _methodId; } + @Override protected int getBodySize() { int size = 6; @@ -90,6 +93,7 @@ public class ChannelCloseBody extends AMQMethodBodyImpl implements EncodableAMQD return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _replyCode ); @@ -98,11 +102,13 @@ public class ChannelCloseBody extends AMQMethodBodyImpl implements EncodableAMQD writeUnsignedShort( buffer, _methodId ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchChannelClose(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ChannelCloseBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseOkBody.java index a9300ea..24e9c7b 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelCloseOkBody.java @@ -43,31 +43,37 @@ public class ChannelCloseOkBody extends AMQMethodBodyImpl implements EncodableAM { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchChannelCloseOk(this, channelId); } + @Override public String toString() { return "[ChannelCloseOkBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowBody.java index e3b41fa..93dc23d 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowBody.java @@ -44,11 +44,13 @@ public class ChannelFlowBody extends AMQMethodBodyImpl implements EncodableAMQDa _active = active; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -59,21 +61,25 @@ public class ChannelFlowBody extends AMQMethodBodyImpl implements EncodableAMQDa return _active; } + @Override protected int getBodySize() { return 1; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeBitfield( buffer, _active ? (byte)1 : (byte)0); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchChannelFlow(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ChannelFlowBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowOkBody.java index 0b403d5..1d7c2a2 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelFlowOkBody.java @@ -44,11 +44,13 @@ public class ChannelFlowOkBody extends AMQMethodBodyImpl implements EncodableAMQ _active = active; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -59,22 +61,26 @@ public class ChannelFlowOkBody extends AMQMethodBodyImpl implements EncodableAMQ return _active; } + @Override protected int getBodySize() { int size = 1; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeBitfield( buffer, _active ? (byte)1 : (byte)0 ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchChannelFlowOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ChannelFlowOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenBody.java index 0233d34..ddf5add 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenBody.java @@ -43,31 +43,37 @@ public class ChannelOpenBody extends AMQMethodBodyImpl implements EncodableAMQDa } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 1; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeAMQShortString( buffer, null ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchChannelOpen(this, channelId); } + @Override public String toString() { return "[ChannelOpenBody] "; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenOkBody.java index 2ea8179..a598e4f 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ChannelOpenOkBody.java @@ -63,22 +63,26 @@ public class ChannelOpenOkBody extends AMQMethodBodyImpl implements EncodableAMQ _isAMQP08 = isAMQP08; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return _isAMQP08 ? 0 : 4; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { if(!_isAMQP08) @@ -87,11 +91,13 @@ public class ChannelOpenOkBody extends AMQMethodBodyImpl implements EncodableAMQ } } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchChannelOpenOk(this, channelId); } + @Override public String toString() { return "[ChannelOpenOkBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/CompositeAMQDataBlock.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/CompositeAMQDataBlock.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/CompositeAMQDataBlock.java index 30e18bd..03bbb1b 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/CompositeAMQDataBlock.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/CompositeAMQDataBlock.java @@ -39,6 +39,7 @@ public class CompositeAMQDataBlock extends AMQDataBlock implements EncodableAMQD } + @Override public long getSize() { long frameSize = 0; @@ -60,6 +61,7 @@ public class CompositeAMQDataBlock extends AMQDataBlock implements EncodableAMQD return size; } + @Override public String toString() { if (_blocks == null) http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectBody.java index f313580..2c0a5bf7 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectBody.java @@ -44,11 +44,13 @@ public class ConfirmSelectBody extends AMQMethodBodyImpl implements EncodableAMQ _nowait = nowait; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -59,21 +61,25 @@ public class ConfirmSelectBody extends AMQMethodBodyImpl implements EncodableAMQ return _nowait; } + @Override protected int getBodySize() { return 1; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeBitfield( buffer, _nowait ? (byte)1 : (byte)0 ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConfirmSelect(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConfirmSelectBody: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectOkBody.java index 4858412..6070a71 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConfirmSelectOkBody.java @@ -42,31 +42,37 @@ public class ConfirmSelectOkBody extends AMQMethodBodyImpl implements EncodableA { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConfirmSelectOk(this, channelId); } + @Override public String toString() { return "[ConfirmSelectOkBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseBody.java index d447b3b..cec8623 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseBody.java @@ -58,11 +58,13 @@ public class ConnectionCloseBody extends AMQMethodBodyImpl implements EncodableA _methodId = methodId; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return _ownMethodId; @@ -85,6 +87,7 @@ public class ConnectionCloseBody extends AMQMethodBodyImpl implements EncodableA return _methodId; } + @Override protected int getBodySize() { int size = 6; @@ -92,6 +95,7 @@ public class ConnectionCloseBody extends AMQMethodBodyImpl implements EncodableA return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _replyCode ); @@ -100,11 +104,13 @@ public class ConnectionCloseBody extends AMQMethodBodyImpl implements EncodableA writeUnsignedShort( buffer, _methodId ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionClose(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionCloseBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseOkBody.java index 052bc57..4510a93 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionCloseOkBody.java @@ -46,31 +46,37 @@ public class ConnectionCloseOkBody extends AMQMethodBodyImpl implements Encodabl } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return _ownMethodId; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionCloseOk(this, channelId); } + @Override public String toString() { return "[ConnectionCloseOkBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenBody.java index 1f36611..c74b36e 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenBody.java @@ -52,11 +52,13 @@ public class ConnectionOpenBody extends AMQMethodBodyImpl implements EncodableAM _insist = insist; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -75,6 +77,7 @@ public class ConnectionOpenBody extends AMQMethodBodyImpl implements EncodableAM return _insist; } + @Override protected int getBodySize() { int size = 1; @@ -83,6 +86,7 @@ public class ConnectionOpenBody extends AMQMethodBodyImpl implements EncodableAM return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeAMQShortString( buffer, _virtualHost ); @@ -90,11 +94,13 @@ public class ConnectionOpenBody extends AMQMethodBodyImpl implements EncodableAM writeBitfield( buffer, _insist ? (byte)1 : (byte)0); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionOpen(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionOpenBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenOkBody.java index a742420..64d5684 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionOpenOkBody.java @@ -48,11 +48,13 @@ public class ConnectionOpenOkBody extends AMQMethodBodyImpl implements Encodable _knownHosts = knownHosts; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -63,6 +65,7 @@ public class ConnectionOpenOkBody extends AMQMethodBodyImpl implements Encodable return _knownHosts; } + @Override protected int getBodySize() { int size = 0; @@ -70,16 +73,19 @@ public class ConnectionOpenOkBody extends AMQMethodBodyImpl implements Encodable return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeAMQShortString( buffer, _knownHosts ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionOpenOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionOpenOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionRedirectBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionRedirectBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionRedirectBody.java index 25db456..bb69255 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionRedirectBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionRedirectBody.java @@ -50,11 +50,13 @@ public class ConnectionRedirectBody extends AMQMethodBodyImpl implements Encodab _knownHosts = knownHosts; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return _ownMethodId; @@ -69,6 +71,7 @@ public class ConnectionRedirectBody extends AMQMethodBodyImpl implements Encodab return _knownHosts; } + @Override protected int getBodySize() { int size = 0; @@ -77,17 +80,20 @@ public class ConnectionRedirectBody extends AMQMethodBodyImpl implements Encodab return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeAMQShortString( buffer, _host ); writeAMQShortString( buffer, _knownHosts ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionRedirect(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionRedirectBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureBody.java index 730800b..c63914b 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureBody.java @@ -49,11 +49,13 @@ public class ConnectionSecureBody extends AMQMethodBodyImpl implements Encodable _challenge = challenge; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -64,6 +66,7 @@ public class ConnectionSecureBody extends AMQMethodBodyImpl implements Encodable return _challenge; } + @Override protected int getBodySize() { int size = 0; @@ -71,16 +74,19 @@ public class ConnectionSecureBody extends AMQMethodBodyImpl implements Encodable return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeBytes( buffer, _challenge ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionSecure(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionSecureBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureOkBody.java index b3ff1b2..7edc2fb 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionSecureOkBody.java @@ -47,11 +47,13 @@ public class ConnectionSecureOkBody extends AMQMethodBodyImpl implements Encodab _response = response; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -62,6 +64,7 @@ public class ConnectionSecureOkBody extends AMQMethodBodyImpl implements Encodab return _response; } + @Override protected int getBodySize() { int size = 0; @@ -69,16 +72,19 @@ public class ConnectionSecureOkBody extends AMQMethodBodyImpl implements Encodab return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeBytes( buffer, _response ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionSecureOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionSecureOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartBody.java index 0888452..7e3010b 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartBody.java @@ -60,11 +60,13 @@ public class ConnectionStartBody extends AMQMethodBodyImpl implements EncodableA _locales = locales; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -91,6 +93,7 @@ public class ConnectionStartBody extends AMQMethodBodyImpl implements EncodableA return _locales; } + @Override protected int getBodySize() { int size = 2; @@ -100,6 +103,7 @@ public class ConnectionStartBody extends AMQMethodBodyImpl implements EncodableA return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedByte( buffer, _versionMajor ); @@ -109,11 +113,13 @@ public class ConnectionStartBody extends AMQMethodBodyImpl implements EncodableA writeBytes( buffer, _locales ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionStart(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionStartBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartOkBody.java index ef22d1f..92e51e7 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartOkBody.java @@ -59,11 +59,13 @@ public class ConnectionStartOkBody extends AMQMethodBodyImpl implements Encodabl _locale = locale; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -86,6 +88,7 @@ public class ConnectionStartOkBody extends AMQMethodBodyImpl implements Encodabl return _locale; } + @Override protected int getBodySize() { int size = 0; @@ -96,6 +99,7 @@ public class ConnectionStartOkBody extends AMQMethodBodyImpl implements Encodabl return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeFieldTable( buffer, _clientProperties ); @@ -104,11 +108,13 @@ public class ConnectionStartOkBody extends AMQMethodBodyImpl implements Encodabl writeAMQShortString( buffer, _locale ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionStartOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionStartOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneBody.java index 231a7ee..3d904b0 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneBody.java @@ -52,11 +52,13 @@ public class ConnectionTuneBody extends AMQMethodBodyImpl implements EncodableAM _heartbeat = heartbeat; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -75,12 +77,14 @@ public class ConnectionTuneBody extends AMQMethodBodyImpl implements EncodableAM return _heartbeat; } + @Override protected int getBodySize() { int size = 8; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _channelMax ); @@ -88,11 +92,13 @@ public class ConnectionTuneBody extends AMQMethodBodyImpl implements EncodableAM writeUnsignedShort( buffer, _heartbeat ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionTune(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionTuneBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneOkBody.java index d94e365..04835b9 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionTuneOkBody.java @@ -52,11 +52,13 @@ public class ConnectionTuneOkBody extends AMQMethodBodyImpl implements Encodable _heartbeat = heartbeat; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -75,12 +77,14 @@ public class ConnectionTuneOkBody extends AMQMethodBodyImpl implements Encodable return _heartbeat; } + @Override protected int getBodySize() { int size = 8; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _channelMax ); @@ -88,11 +92,13 @@ public class ConnectionTuneOkBody extends AMQMethodBodyImpl implements Encodable writeUnsignedShort( buffer, _heartbeat ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchConnectionTuneOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ConnectionTuneOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentBody.java index 2df7243..88468a3 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentBody.java @@ -44,16 +44,19 @@ public class ContentBody implements AMQBody } + @Override public byte getFrameType() { return TYPE; } + @Override public int getSize() { return _payload == null ? 0 : _payload.remaining(); } + @Override public void handle(final int channelId, final AMQVersionAwareProtocolSession session) throws QpidException { http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentHeaderBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentHeaderBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentHeaderBody.java index 4cef06c..0b55f4c 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentHeaderBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ContentHeaderBody.java @@ -58,6 +58,7 @@ public class ContentHeaderBody implements AMQBody _bodySize = bodySize; } + @Override public byte getFrameType() { return TYPE; @@ -80,6 +81,7 @@ public class ContentHeaderBody implements AMQBody return body; } + @Override public int getSize() { return 2 + 2 + 8 + 2 + _properties.getPropertyListSize(); @@ -108,6 +110,7 @@ public class ContentHeaderBody implements AMQBody return HEADER_SIZE + _properties.writePropertyListPayload(buf); } + @Override public void handle(final int channelId, final AMQVersionAwareProtocolSession session) throws QpidException { http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundBody.java index 6b5be52..b1b479a 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundBody.java @@ -53,11 +53,13 @@ public class ExchangeBoundBody extends AMQMethodBodyImpl implements EncodableAMQ _queue = queue; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -76,6 +78,7 @@ public class ExchangeBoundBody extends AMQMethodBodyImpl implements EncodableAMQ return _queue; } + @Override protected int getBodySize() { int size = 0; @@ -85,6 +88,7 @@ public class ExchangeBoundBody extends AMQMethodBodyImpl implements EncodableAMQ return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeAMQShortString( buffer, _exchange ); @@ -92,11 +96,13 @@ public class ExchangeBoundBody extends AMQMethodBodyImpl implements EncodableAMQ writeAMQShortString( buffer, _queue ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchExchangeBound(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ExchangeBoundBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundOkBody.java index af660fe..c634418 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeBoundOkBody.java @@ -57,11 +57,13 @@ public class ExchangeBoundOkBody extends AMQMethodBodyImpl implements EncodableA _replyText = replyText; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -76,6 +78,7 @@ public class ExchangeBoundOkBody extends AMQMethodBodyImpl implements EncodableA return _replyText; } + @Override protected int getBodySize() { int size = 2; @@ -83,17 +86,20 @@ public class ExchangeBoundOkBody extends AMQMethodBodyImpl implements EncodableA return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _replyCode ); writeAMQShortString( buffer, _replyText ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchExchangeBoundOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ExchangeBoundOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareBody.java index b63de29..b940a26 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareBody.java @@ -92,11 +92,13 @@ public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableA _arguments = arguments; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -139,6 +141,7 @@ public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableA return _arguments; } + @Override protected int getBodySize() { int size = 3; @@ -148,6 +151,7 @@ public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableA return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _ticket ); @@ -157,11 +161,13 @@ public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableA writeFieldTable( buffer, _arguments ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchExchangeDeclare(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ExchangeDeclareBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareOkBody.java index a731c69..002b4b4 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeclareOkBody.java @@ -43,32 +43,38 @@ public class ExchangeDeclareOkBody extends AMQMethodBodyImpl implements Encodabl { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { int size = 0; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchExchangeDeclareOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ExchangeDeclareOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteBody.java index f4a1323..e35f981 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteBody.java @@ -64,11 +64,13 @@ public class ExchangeDeleteBody extends AMQMethodBodyImpl implements EncodableAM _bitfield0 = bitfield0; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -91,6 +93,7 @@ public class ExchangeDeleteBody extends AMQMethodBodyImpl implements EncodableAM return (((int)(_bitfield0)) & ( 1 << 1)) != 0; } + @Override protected int getBodySize() { int size = 3; @@ -98,6 +101,7 @@ public class ExchangeDeleteBody extends AMQMethodBodyImpl implements EncodableAM return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _ticket ); @@ -105,11 +109,13 @@ public class ExchangeDeleteBody extends AMQMethodBodyImpl implements EncodableAM writeBitfield( buffer, _bitfield0 ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchExchangeDelete(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ExchangeDeleteBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteOkBody.java index 9bd7c53..cf07788 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ExchangeDeleteOkBody.java @@ -43,32 +43,38 @@ public class ExchangeDeleteOkBody extends AMQMethodBodyImpl implements Encodable { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { int size = 0; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchExchangeDeleteOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[ExchangeDeleteOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/HeartbeatBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/HeartbeatBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/HeartbeatBody.java index 10885d1..b76f8a1 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/HeartbeatBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/HeartbeatBody.java @@ -47,11 +47,13 @@ public class HeartbeatBody implements AMQBody } } + @Override public byte getFrameType() { return TYPE; } + @Override public int getSize() { return 0;//heartbeats we generate have no payload @@ -63,6 +65,7 @@ public class HeartbeatBody implements AMQBody return 0l; } + @Override public void handle(final int channelId, final AMQVersionAwareProtocolSession session) throws QpidException { http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ProtocolInitiation.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ProtocolInitiation.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ProtocolInitiation.java index c021312..7fa6254 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ProtocolInitiation.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ProtocolInitiation.java @@ -73,6 +73,7 @@ public class ProtocolInitiation extends AMQDataBlock implements EncodableAMQData } + @Override public long getSize() { return 4 + 1 + 1 + 1 + 1; @@ -94,6 +95,7 @@ public class ProtocolInitiation extends AMQDataBlock implements EncodableAMQData return 8l; } + @Override public boolean equals(Object o) { if (this == o) http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindBody.java index e9f0839..3d3cc90 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindBody.java @@ -71,11 +71,13 @@ public class QueueBindBody extends AMQMethodBodyImpl implements EncodableAMQData _arguments = arguments; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -106,6 +108,7 @@ public class QueueBindBody extends AMQMethodBodyImpl implements EncodableAMQData return _arguments; } + @Override protected int getBodySize() { int size = 3; @@ -116,6 +119,7 @@ public class QueueBindBody extends AMQMethodBodyImpl implements EncodableAMQData return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _ticket ); @@ -126,11 +130,13 @@ public class QueueBindBody extends AMQMethodBodyImpl implements EncodableAMQData writeFieldTable( buffer, _arguments ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueBind(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueBindBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindOkBody.java index d377268..3534351 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueBindOkBody.java @@ -43,32 +43,38 @@ public class QueueBindOkBody extends AMQMethodBodyImpl implements EncodableAMQDa { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { int size = 0; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueBindOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueBindOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareBody.java index 0d71d64..3a9a966 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareBody.java @@ -89,11 +89,13 @@ public class QueueDeclareBody extends AMQMethodBodyImpl implements EncodableAMQD _arguments = arguments; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -132,6 +134,7 @@ public class QueueDeclareBody extends AMQMethodBodyImpl implements EncodableAMQD return _arguments; } + @Override protected int getBodySize() { int size = 3; @@ -140,6 +143,7 @@ public class QueueDeclareBody extends AMQMethodBodyImpl implements EncodableAMQD return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _ticket ); @@ -148,11 +152,13 @@ public class QueueDeclareBody extends AMQMethodBodyImpl implements EncodableAMQD writeFieldTable( buffer, _arguments ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueDeclare(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueDeclareBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareOkBody.java index 863f42b..0bd30d8 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeclareOkBody.java @@ -53,11 +53,13 @@ public class QueueDeclareOkBody extends AMQMethodBodyImpl implements EncodableAM _consumerCount = consumerCount; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -76,6 +78,7 @@ public class QueueDeclareOkBody extends AMQMethodBodyImpl implements EncodableAM return _consumerCount; } + @Override protected int getBodySize() { int size = 8; @@ -83,6 +86,7 @@ public class QueueDeclareOkBody extends AMQMethodBodyImpl implements EncodableAM return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeAMQShortString( buffer, _queue ); @@ -90,11 +94,13 @@ public class QueueDeclareOkBody extends AMQMethodBodyImpl implements EncodableAM writeUnsignedInteger( buffer, _consumerCount ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueDeclareOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueDeclareOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteBody.java index 78c9bf9..98fdcd8 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteBody.java @@ -70,11 +70,13 @@ public class QueueDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDa _bitfield0 = bitfield0; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -101,6 +103,7 @@ public class QueueDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDa return (((int)(_bitfield0)) & ( 1 << 2)) != 0; } + @Override protected int getBodySize() { int size = 3; @@ -108,6 +111,7 @@ public class QueueDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDa return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _ticket ); @@ -115,11 +119,13 @@ public class QueueDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDa writeBitfield( buffer, _bitfield0 ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueDelete(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueDeleteBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteOkBody.java index adef40f..774932b 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueDeleteOkBody.java @@ -46,11 +46,13 @@ public class QueueDeleteOkBody extends AMQMethodBodyImpl implements EncodableAMQ _messageCount = messageCount; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -61,22 +63,26 @@ public class QueueDeleteOkBody extends AMQMethodBodyImpl implements EncodableAMQ return _messageCount; } + @Override protected int getBodySize() { int size = 4; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedInteger( buffer, _messageCount ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueDeleteOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueDeleteOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeBody.java index d563020..696ad09 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeBody.java @@ -58,11 +58,13 @@ public class QueuePurgeBody extends AMQMethodBodyImpl implements EncodableAMQDat _bitfield0 = bitfield0; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -81,6 +83,7 @@ public class QueuePurgeBody extends AMQMethodBodyImpl implements EncodableAMQDat return (((int)(_bitfield0)) & ( 1 << 0)) != 0; } + @Override protected int getBodySize() { int size = 3; @@ -88,6 +91,7 @@ public class QueuePurgeBody extends AMQMethodBodyImpl implements EncodableAMQDat return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _ticket ); @@ -95,11 +99,13 @@ public class QueuePurgeBody extends AMQMethodBodyImpl implements EncodableAMQDat writeBitfield( buffer, _bitfield0 ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueuePurge(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueuePurgeBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeOkBody.java index 345b8ae..f05b65d 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueuePurgeOkBody.java @@ -46,11 +46,13 @@ public class QueuePurgeOkBody extends AMQMethodBodyImpl implements EncodableAMQD _messageCount = messageCount; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -61,22 +63,26 @@ public class QueuePurgeOkBody extends AMQMethodBodyImpl implements EncodableAMQD return _messageCount; } + @Override protected int getBodySize() { int size = 4; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedInteger( buffer, _messageCount ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueuePurgeOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueuePurgeOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindBody.java index 15eeb90..c45c477 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindBody.java @@ -62,11 +62,13 @@ public class QueueUnbindBody extends AMQMethodBodyImpl implements EncodableAMQDa _arguments = arguments; } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; @@ -93,6 +95,7 @@ public class QueueUnbindBody extends AMQMethodBodyImpl implements EncodableAMQDa return _arguments; } + @Override protected int getBodySize() { int size = 2; @@ -103,6 +106,7 @@ public class QueueUnbindBody extends AMQMethodBodyImpl implements EncodableAMQDa return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { writeUnsignedShort( buffer, _ticket ); @@ -112,11 +116,13 @@ public class QueueUnbindBody extends AMQMethodBodyImpl implements EncodableAMQDa writeFieldTable( buffer, _arguments ); } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueUnbind(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueUnbindBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindOkBody.java index b90023e..3c0ed24 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/QueueUnbindOkBody.java @@ -43,32 +43,38 @@ public class QueueUnbindOkBody extends AMQMethodBodyImpl implements EncodableAMQ { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { int size = 0; return size; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchQueueUnbindOk(this, channelId); } + @Override public String toString() { StringBuilder buf = new StringBuilder("[QueueUnbindOkBodyImpl: "); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ServerChannelMethodProcessor.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ServerChannelMethodProcessor.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ServerChannelMethodProcessor.java index 6ceef3a..ac081a2 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ServerChannelMethodProcessor.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/ServerChannelMethodProcessor.java @@ -80,6 +80,7 @@ public interface ServerChannelMethodProcessor extends ChannelMethodProcessor void receiveBasicGet(AMQShortString queue, boolean noAck); + @Override void receiveBasicAck(long deliveryTag, boolean multiple); void receiveBasicReject(long deliveryTag, boolean requeue); http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitBody.java index b469ec3..6d129da 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitBody.java @@ -45,31 +45,37 @@ public class TxCommitBody extends AMQMethodBodyImpl implements EncodableAMQDataB { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchTxCommit(this, channelId); } + @Override public String toString() { return "[TxCommitBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitOkBody.java index ced756e..557c5dd 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxCommitOkBody.java @@ -43,31 +43,37 @@ public class TxCommitOkBody extends AMQMethodBodyImpl implements EncodableAMQDat { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchTxCommitOk(this, channelId); } + @Override public String toString() { return "[TxCommitOkBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackBody.java index 8fd33e7..cd5f640 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackBody.java @@ -43,31 +43,37 @@ public class TxRollbackBody extends AMQMethodBodyImpl implements EncodableAMQDat { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchTxRollback(this, channelId); } + @Override public String toString() { return "[TxRollbackBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackOkBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackOkBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackOkBody.java index ea5f152..e306c54 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackOkBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxRollbackOkBody.java @@ -44,31 +44,37 @@ public class TxRollbackOkBody extends AMQMethodBodyImpl implements EncodableAMQD { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchTxRollbackOk(this, channelId); } + @Override public String toString() { return "[TxRollbackOkBody]"; http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/ec1bd825/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxSelectBody.java ---------------------------------------------------------------------- diff --git a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxSelectBody.java b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxSelectBody.java index aafc522..402fad3 100644 --- a/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxSelectBody.java +++ b/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/transport/TxSelectBody.java @@ -46,31 +46,37 @@ public class TxSelectBody extends AMQMethodBodyImpl implements EncodableAMQDataB { } + @Override public int getClazz() { return CLASS_ID; } + @Override public int getMethod() { return METHOD_ID; } + @Override protected int getBodySize() { return 0; } + @Override public void writeMethodPayload(QpidByteBuffer buffer) { } + @Override public boolean execute(MethodDispatcher dispatcher, int channelId) throws QpidException { return dispatcher.dispatchTxSelect(this, channelId); } + @Override public String toString() { return "[TxSelectBody]"; --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org