You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2017/07/18 10:03:45 UTC
[04/12] qpid-broker-j git commit: NO-JIRA : Add missing @Overrides
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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org