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 2014/09/28 18:46:36 UTC
svn commit: r1628082 [3/4] - in
/qpid/branches/QPID-6125-ProtocolRefactoring/java:
broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/
broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/...
Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java?rev=1628082&r1=1628081&r2=1628082&view=diff
==============================================================================
--- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java (original)
+++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java Sun Sep 28 16:46:34 2014
@@ -24,7 +24,6 @@ package org.apache.qpid.framing.amqp_0_9
import org.apache.qpid.framing.AMQMethodBody;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.framing.BasicPublishBody;
-import org.apache.qpid.framing.BasicPublishBodyImpl;
import org.apache.qpid.framing.abstraction.AbstractMethodConverter;
import org.apache.qpid.framing.abstraction.MessagePublishInfo;
import org.apache.qpid.framing.abstraction.MessagePublishInfoImpl;
@@ -57,7 +56,7 @@ public class MethodConverter_0_9 extends
public AMQMethodBody convertToBody(MessagePublishInfo info)
{
- return new BasicPublishBodyImpl(0,
+ return new BasicPublishBody(0,
info.getExchange(),
info.getRoutingKey(),
info.isMandatory(),
Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java?rev=1628082&r1=1628081&r2=1628082&view=diff
==============================================================================
--- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java (original)
+++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java Sun Sep 28 16:46:34 2014
@@ -62,14 +62,14 @@ public class MethodRegistry_0_9 extends
_factories[10] = new AMQMethodBodyInstanceFactory[52];
- _factories[10][10] = ConnectionStartBodyImpl.getFactory();
- _factories[10][11] = ConnectionStartOkBodyImpl.getFactory();
- _factories[10][20] = ConnectionSecureBodyImpl.getFactory();
- _factories[10][21] = ConnectionSecureOkBodyImpl.getFactory();
- _factories[10][30] = ConnectionTuneBodyImpl.getFactory();
- _factories[10][31] = ConnectionTuneOkBodyImpl.getFactory();
- _factories[10][40] = ConnectionOpenBodyImpl.getFactory();
- _factories[10][41] = ConnectionOpenOkBodyImpl.getFactory();
+ _factories[10][10] = ConnectionStartBody.getFactory();
+ _factories[10][11] = ConnectionStartOkBody.getFactory();
+ _factories[10][20] = ConnectionSecureBody.getFactory();
+ _factories[10][21] = ConnectionSecureOkBody.getFactory();
+ _factories[10][30] = ConnectionTuneBody.getFactory();
+ _factories[10][31] = ConnectionTuneOkBody.getFactory();
+ _factories[10][40] = ConnectionOpenBody.getFactory();
+ _factories[10][41] = ConnectionOpenOkBody.getFactory();
_factories[10][42] = ConnectionRedirectBodyImpl.getFactory();
_factories[10][50] = ConnectionCloseBodyImpl.getFactory();
_factories[10][51] = ConnectionCloseOkBodyImpl.getFactory();
@@ -80,12 +80,12 @@ public class MethodRegistry_0_9 extends
_factories[20] = new AMQMethodBodyInstanceFactory[81];
- _factories[20][10] = ChannelOpenBodyImpl.getFactory();
+ _factories[20][10] = ChannelOpenBody.getFactory();
_factories[20][11] = ChannelOpenOkBodyImpl.getFactory();
- _factories[20][20] = ChannelFlowBodyImpl.getFactory();
- _factories[20][21] = ChannelFlowOkBodyImpl.getFactory();
- _factories[20][40] = ChannelCloseBodyImpl.getFactory();
- _factories[20][41] = ChannelCloseOkBodyImpl.getFactory();
+ _factories[20][20] = ChannelFlowBody.getFactory();
+ _factories[20][21] = ChannelFlowOkBody.getFactory();
+ _factories[20][40] = ChannelCloseBody.getFactory();
+ _factories[20][41] = ChannelCloseOkBody.getFactory();
@@ -102,12 +102,12 @@ public class MethodRegistry_0_9 extends
_factories[40] = new AMQMethodBodyInstanceFactory[24];
- _factories[40][10] = ExchangeDeclareBodyImpl.getFactory();
- _factories[40][11] = ExchangeDeclareOkBodyImpl.getFactory();
- _factories[40][20] = ExchangeDeleteBodyImpl.getFactory();
- _factories[40][21] = ExchangeDeleteOkBodyImpl.getFactory();
- _factories[40][22] = ExchangeBoundBodyImpl.getFactory();
- _factories[40][23] = ExchangeBoundOkBodyImpl.getFactory();
+ _factories[40][10] = ExchangeDeclareBody.getFactory();
+ _factories[40][11] = ExchangeDeclareOkBody.getFactory();
+ _factories[40][20] = ExchangeDeleteBody.getFactory();
+ _factories[40][21] = ExchangeDeleteOkBody.getFactory();
+ _factories[40][22] = ExchangeBoundBody.getFactory();
+ _factories[40][23] = ExchangeBoundOkBody.getFactory();
@@ -115,14 +115,14 @@ public class MethodRegistry_0_9 extends
_factories[50] = new AMQMethodBodyInstanceFactory[52];
- _factories[50][10] = QueueDeclareBodyImpl.getFactory();
- _factories[50][11] = QueueDeclareOkBodyImpl.getFactory();
- _factories[50][20] = QueueBindBodyImpl.getFactory();
- _factories[50][21] = QueueBindOkBodyImpl.getFactory();
- _factories[50][30] = QueuePurgeBodyImpl.getFactory();
- _factories[50][31] = QueuePurgeOkBodyImpl.getFactory();
- _factories[50][40] = QueueDeleteBodyImpl.getFactory();
- _factories[50][41] = QueueDeleteOkBodyImpl.getFactory();
+ _factories[50][10] = QueueDeclareBody.getFactory();
+ _factories[50][11] = QueueDeclareOkBody.getFactory();
+ _factories[50][20] = QueueBindBody.getFactory();
+ _factories[50][21] = QueueBindOkBody.getFactory();
+ _factories[50][30] = QueuePurgeBody.getFactory();
+ _factories[50][31] = QueuePurgeOkBody.getFactory();
+ _factories[50][40] = QueueDeleteBody.getFactory();
+ _factories[50][41] = QueueDeleteOkBody.getFactory();
_factories[50][50] = QueueUnbindBodyImpl.getFactory();
_factories[50][51] = QueueUnbindOkBodyImpl.getFactory();
@@ -132,21 +132,21 @@ public class MethodRegistry_0_9 extends
_factories[60] = new AMQMethodBodyInstanceFactory[103];
- _factories[60][10] = BasicQosBodyImpl.getFactory();
- _factories[60][11] = BasicQosOkBodyImpl.getFactory();
- _factories[60][20] = BasicConsumeBodyImpl.getFactory();
- _factories[60][21] = BasicConsumeOkBodyImpl.getFactory();
- _factories[60][30] = BasicCancelBodyImpl.getFactory();
- _factories[60][31] = BasicCancelOkBodyImpl.getFactory();
- _factories[60][40] = BasicPublishBodyImpl.getFactory();
- _factories[60][50] = BasicReturnBodyImpl.getFactory();
- _factories[60][60] = BasicDeliverBodyImpl.getFactory();
- _factories[60][70] = BasicGetBodyImpl.getFactory();
- _factories[60][71] = BasicGetOkBodyImpl.getFactory();
- _factories[60][72] = BasicGetEmptyBodyImpl.getFactory();
- _factories[60][80] = BasicAckBodyImpl.getFactory();
- _factories[60][90] = BasicRejectBodyImpl.getFactory();
- _factories[60][100] = BasicRecoverBodyImpl.getFactory();
+ _factories[60][10] = BasicQosBody.getFactory();
+ _factories[60][11] = BasicQosOkBody.getFactory();
+ _factories[60][20] = BasicConsumeBody.getFactory();
+ _factories[60][21] = BasicConsumeOkBody.getFactory();
+ _factories[60][30] = BasicCancelBody.getFactory();
+ _factories[60][31] = BasicCancelOkBody.getFactory();
+ _factories[60][40] = BasicPublishBody.getFactory();
+ _factories[60][50] = BasicReturnBody.getFactory();
+ _factories[60][60] = BasicDeliverBody.getFactory();
+ _factories[60][70] = BasicGetBody.getFactory();
+ _factories[60][71] = BasicGetOkBody.getFactory();
+ _factories[60][72] = BasicGetEmptyBody.getFactory();
+ _factories[60][80] = BasicAckBody.getFactory();
+ _factories[60][90] = BasicRejectBody.getFactory();
+ _factories[60][100] = BasicRecoverBody.getFactory();
_factories[60][101] = BasicRecoverSyncOkBodyImpl.getFactory();
_factories[60][102] = BasicRecoverSyncBodyImpl.getFactory();
@@ -156,12 +156,12 @@ public class MethodRegistry_0_9 extends
_factories[90] = new AMQMethodBodyInstanceFactory[32];
- _factories[90][10] = TxSelectBodyImpl.getFactory();
- _factories[90][11] = TxSelectOkBodyImpl.getFactory();
- _factories[90][20] = TxCommitBodyImpl.getFactory();
- _factories[90][21] = TxCommitOkBodyImpl.getFactory();
- _factories[90][30] = TxRollbackBodyImpl.getFactory();
- _factories[90][31] = TxRollbackOkBodyImpl.getFactory();
+ _factories[90][10] = TxSelectBody.getFactory();
+ _factories[90][11] = TxSelectOkBody.getFactory();
+ _factories[90][20] = TxCommitBody.getFactory();
+ _factories[90][21] = TxCommitOkBody.getFactory();
+ _factories[90][30] = TxRollbackBody.getFactory();
+ _factories[90][31] = TxRollbackOkBody.getFactory();
}
@@ -223,14 +223,14 @@ public class MethodRegistry_0_9 extends
public ConnectionStartBody createConnectionStartBody(
- final short versionMajor,
- final short versionMinor,
- final FieldTable serverProperties,
- final byte[] mechanisms,
- final byte[] locales
- )
+ final short versionMajor,
+ final short versionMinor,
+ final FieldTable serverProperties,
+ final byte[] mechanisms,
+ final byte[] locales
+ )
{
- return new ConnectionStartBodyImpl(
+ return new ConnectionStartBody(
versionMajor,
versionMinor,
serverProperties,
@@ -240,13 +240,13 @@ public class MethodRegistry_0_9 extends
}
public ConnectionStartOkBody createConnectionStartOkBody(
- final FieldTable clientProperties,
- final AMQShortString mechanism,
- final byte[] response,
- final AMQShortString locale
- )
+ final FieldTable clientProperties,
+ final AMQShortString mechanism,
+ final byte[] response,
+ final AMQShortString locale
+ )
{
- return new ConnectionStartOkBodyImpl(
+ return new ConnectionStartOkBody(
clientProperties,
mechanism,
response,
@@ -255,30 +255,30 @@ public class MethodRegistry_0_9 extends
}
public ConnectionSecureBody createConnectionSecureBody(
- final byte[] challenge
- )
+ final byte[] challenge
+ )
{
- return new ConnectionSecureBodyImpl(
+ return new ConnectionSecureBody(
challenge
);
}
public ConnectionSecureOkBody createConnectionSecureOkBody(
- final byte[] response
- )
+ final byte[] response
+ )
{
- return new ConnectionSecureOkBodyImpl(
+ return new ConnectionSecureOkBody(
response
);
}
public ConnectionTuneBody createConnectionTuneBody(
- final int channelMax,
- final long frameMax,
- final int heartbeat
- )
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ )
{
- return new ConnectionTuneBodyImpl(
+ return new ConnectionTuneBody(
channelMax,
frameMax,
heartbeat
@@ -286,12 +286,12 @@ public class MethodRegistry_0_9 extends
}
public ConnectionTuneOkBody createConnectionTuneOkBody(
- final int channelMax,
- final long frameMax,
- final int heartbeat
- )
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ )
{
- return new ConnectionTuneOkBodyImpl(
+ return new ConnectionTuneOkBody(
channelMax,
frameMax,
heartbeat
@@ -299,12 +299,12 @@ public class MethodRegistry_0_9 extends
}
public ConnectionOpenBody createConnectionOpenBody(
- final AMQShortString virtualHost,
- final AMQShortString capabilities,
- final boolean insist
- )
+ final AMQShortString virtualHost,
+ final AMQShortString capabilities,
+ final boolean insist
+ )
{
- return new ConnectionOpenBodyImpl(
+ return new ConnectionOpenBody(
virtualHost,
capabilities,
insist
@@ -312,10 +312,10 @@ public class MethodRegistry_0_9 extends
}
public ConnectionOpenOkBody createConnectionOpenOkBody(
- final AMQShortString knownHosts
- )
+ final AMQShortString knownHosts
+ )
{
- return new ConnectionOpenOkBodyImpl(
+ return new ConnectionOpenOkBody(
knownHosts
);
}
@@ -357,10 +357,10 @@ public class MethodRegistry_0_9 extends
public ChannelOpenBody createChannelOpenBody(
- final AMQShortString outOfBand
- )
+ final AMQShortString outOfBand
+ )
{
- return new ChannelOpenBodyImpl(
+ return new ChannelOpenBody(
outOfBand
);
}
@@ -375,31 +375,31 @@ public class MethodRegistry_0_9 extends
}
public ChannelFlowBody createChannelFlowBody(
- final boolean active
- )
+ final boolean active
+ )
{
- return new ChannelFlowBodyImpl(
+ return new ChannelFlowBody(
active
);
}
public ChannelFlowOkBody createChannelFlowOkBody(
- final boolean active
- )
+ final boolean active
+ )
{
- return new ChannelFlowOkBodyImpl(
+ return new ChannelFlowOkBody(
active
);
}
public ChannelCloseBody createChannelCloseBody(
- final int replyCode,
- final AMQShortString replyText,
- final int classId,
- final int methodId
- )
+ final int replyCode,
+ final AMQShortString replyText,
+ final int classId,
+ final int methodId
+ )
{
- return new ChannelCloseBodyImpl(
+ return new ChannelCloseBody(
replyCode,
replyText,
classId,
@@ -408,9 +408,9 @@ public class MethodRegistry_0_9 extends
}
public ChannelCloseOkBody createChannelCloseOkBody(
- )
+ )
{
- return new ChannelCloseOkBodyImpl(
+ return new ChannelCloseOkBody(
);
}
@@ -447,18 +447,18 @@ public class MethodRegistry_0_9 extends
public ExchangeDeclareBody createExchangeDeclareBody(
- final int ticket,
- final AMQShortString exchange,
- final AMQShortString type,
- final boolean passive,
- final boolean durable,
- final boolean autoDelete,
- final boolean internal,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString type,
+ final boolean passive,
+ final boolean durable,
+ final boolean autoDelete,
+ final boolean internal,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new ExchangeDeclareBodyImpl(
+ return new ExchangeDeclareBody(
ticket,
exchange,
type,
@@ -472,20 +472,20 @@ public class MethodRegistry_0_9 extends
}
public ExchangeDeclareOkBody createExchangeDeclareOkBody(
- )
+ )
{
- return new ExchangeDeclareOkBodyImpl(
+ return new ExchangeDeclareOkBody(
);
}
public ExchangeDeleteBody createExchangeDeleteBody(
- final int ticket,
- final AMQShortString exchange,
- final boolean ifUnused,
- final boolean nowait
- )
+ final int ticket,
+ final AMQShortString exchange,
+ final boolean ifUnused,
+ final boolean nowait
+ )
{
- return new ExchangeDeleteBodyImpl(
+ return new ExchangeDeleteBody(
ticket,
exchange,
ifUnused,
@@ -494,19 +494,19 @@ public class MethodRegistry_0_9 extends
}
public ExchangeDeleteOkBody createExchangeDeleteOkBody(
- )
+ )
{
- return new ExchangeDeleteOkBodyImpl(
+ return new ExchangeDeleteOkBody(
);
}
public ExchangeBoundBody createExchangeBoundBody(
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final AMQShortString queue
- )
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final AMQShortString queue
+ )
{
- return new ExchangeBoundBodyImpl(
+ return new ExchangeBoundBody(
exchange,
routingKey,
queue
@@ -514,11 +514,11 @@ public class MethodRegistry_0_9 extends
}
public ExchangeBoundOkBody createExchangeBoundOkBody(
- final int replyCode,
- final AMQShortString replyText
- )
+ final int replyCode,
+ final AMQShortString replyText
+ )
{
- return new ExchangeBoundOkBodyImpl(
+ return new ExchangeBoundOkBody(
replyCode,
replyText
);
@@ -528,17 +528,17 @@ public class MethodRegistry_0_9 extends
public QueueDeclareBody createQueueDeclareBody(
- final int ticket,
- final AMQShortString queue,
- final boolean passive,
- final boolean durable,
- final boolean exclusive,
- final boolean autoDelete,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean passive,
+ final boolean durable,
+ final boolean exclusive,
+ final boolean autoDelete,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new QueueDeclareBodyImpl(
+ return new QueueDeclareBody(
ticket,
queue,
passive,
@@ -551,12 +551,12 @@ public class MethodRegistry_0_9 extends
}
public QueueDeclareOkBody createQueueDeclareOkBody(
- final AMQShortString queue,
- final long messageCount,
- final long consumerCount
- )
+ final AMQShortString queue,
+ final long messageCount,
+ final long consumerCount
+ )
{
- return new QueueDeclareOkBodyImpl(
+ return new QueueDeclareOkBody(
queue,
messageCount,
consumerCount
@@ -564,15 +564,15 @@ public class MethodRegistry_0_9 extends
}
public QueueBindBody createQueueBindBody(
- final int ticket,
- final AMQShortString queue,
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new QueueBindBodyImpl(
+ return new QueueBindBody(
ticket,
queue,
exchange,
@@ -583,19 +583,19 @@ public class MethodRegistry_0_9 extends
}
public QueueBindOkBody createQueueBindOkBody(
- )
+ )
{
- return new QueueBindOkBodyImpl(
+ return new QueueBindOkBody(
);
}
public QueuePurgeBody createQueuePurgeBody(
- final int ticket,
- final AMQShortString queue,
- final boolean nowait
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean nowait
+ )
{
- return new QueuePurgeBodyImpl(
+ return new QueuePurgeBody(
ticket,
queue,
nowait
@@ -603,23 +603,23 @@ public class MethodRegistry_0_9 extends
}
public QueuePurgeOkBody createQueuePurgeOkBody(
- final long messageCount
- )
+ final long messageCount
+ )
{
- return new QueuePurgeOkBodyImpl(
+ return new QueuePurgeOkBody(
messageCount
);
}
public QueueDeleteBody createQueueDeleteBody(
- final int ticket,
- final AMQShortString queue,
- final boolean ifUnused,
- final boolean ifEmpty,
- final boolean nowait
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean ifUnused,
+ final boolean ifEmpty,
+ final boolean nowait
+ )
{
- return new QueueDeleteBodyImpl(
+ return new QueueDeleteBody(
ticket,
queue,
ifUnused,
@@ -629,10 +629,10 @@ public class MethodRegistry_0_9 extends
}
public QueueDeleteOkBody createQueueDeleteOkBody(
- final long messageCount
- )
+ final long messageCount
+ )
{
- return new QueueDeleteOkBodyImpl(
+ return new QueueDeleteOkBody(
messageCount
);
}
@@ -665,12 +665,12 @@ public class MethodRegistry_0_9 extends
public BasicQosBody createBasicQosBody(
- final long prefetchSize,
- final int prefetchCount,
- final boolean global
- )
+ final long prefetchSize,
+ final int prefetchCount,
+ final boolean global
+ )
{
- return new BasicQosBodyImpl(
+ return new BasicQosBody(
prefetchSize,
prefetchCount,
global
@@ -678,24 +678,24 @@ public class MethodRegistry_0_9 extends
}
public BasicQosOkBody createBasicQosOkBody(
- )
+ )
{
- return new BasicQosOkBodyImpl(
+ return new BasicQosOkBody(
);
}
public BasicConsumeBody createBasicConsumeBody(
- final int ticket,
- final AMQShortString queue,
- final AMQShortString consumerTag,
- final boolean noLocal,
- final boolean noAck,
- final boolean exclusive,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString consumerTag,
+ final boolean noLocal,
+ final boolean noAck,
+ final boolean exclusive,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new BasicConsumeBodyImpl(
+ return new BasicConsumeBody(
ticket,
queue,
consumerTag,
@@ -708,43 +708,43 @@ public class MethodRegistry_0_9 extends
}
public BasicConsumeOkBody createBasicConsumeOkBody(
- final AMQShortString consumerTag
- )
+ final AMQShortString consumerTag
+ )
{
- return new BasicConsumeOkBodyImpl(
+ return new BasicConsumeOkBody(
consumerTag
);
}
public BasicCancelBody createBasicCancelBody(
- final AMQShortString consumerTag,
- final boolean nowait
- )
+ final AMQShortString consumerTag,
+ final boolean nowait
+ )
{
- return new BasicCancelBodyImpl(
+ return new BasicCancelBody(
consumerTag,
nowait
);
}
public BasicCancelOkBody createBasicCancelOkBody(
- final AMQShortString consumerTag
- )
+ final AMQShortString consumerTag
+ )
{
- return new BasicCancelOkBodyImpl(
+ return new BasicCancelOkBody(
consumerTag
);
}
public BasicPublishBody createBasicPublishBody(
- final int ticket,
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final boolean mandatory,
- final boolean immediate
- )
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean mandatory,
+ final boolean immediate
+ )
{
- return new BasicPublishBodyImpl(
+ return new BasicPublishBody(
ticket,
exchange,
routingKey,
@@ -754,13 +754,13 @@ public class MethodRegistry_0_9 extends
}
public BasicReturnBody createBasicReturnBody(
- final int replyCode,
- final AMQShortString replyText,
- final AMQShortString exchange,
- final AMQShortString routingKey
- )
+ final int replyCode,
+ final AMQShortString replyText,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ )
{
- return new BasicReturnBodyImpl(
+ return new BasicReturnBody(
replyCode,
replyText,
exchange,
@@ -769,14 +769,14 @@ public class MethodRegistry_0_9 extends
}
public BasicDeliverBody createBasicDeliverBody(
- final AMQShortString consumerTag,
- final long deliveryTag,
- final boolean redelivered,
- final AMQShortString exchange,
- final AMQShortString routingKey
- )
+ final AMQShortString consumerTag,
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ )
{
- return new BasicDeliverBodyImpl(
+ return new BasicDeliverBody(
consumerTag,
deliveryTag,
redelivered,
@@ -786,12 +786,12 @@ public class MethodRegistry_0_9 extends
}
public BasicGetBody createBasicGetBody(
- final int ticket,
- final AMQShortString queue,
- final boolean noAck
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean noAck
+ )
{
- return new BasicGetBodyImpl(
+ return new BasicGetBody(
ticket,
queue,
noAck
@@ -799,14 +799,14 @@ public class MethodRegistry_0_9 extends
}
public BasicGetOkBody createBasicGetOkBody(
- final long deliveryTag,
- final boolean redelivered,
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final long messageCount
- )
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final long messageCount
+ )
{
- return new BasicGetOkBodyImpl(
+ return new BasicGetOkBody(
deliveryTag,
redelivered,
exchange,
@@ -816,41 +816,41 @@ public class MethodRegistry_0_9 extends
}
public BasicGetEmptyBody createBasicGetEmptyBody(
- final AMQShortString clusterId
- )
+ final AMQShortString clusterId
+ )
{
- return new BasicGetEmptyBodyImpl(
+ return new BasicGetEmptyBody(
clusterId
);
}
public BasicAckBody createBasicAckBody(
- final long deliveryTag,
- final boolean multiple
- )
+ final long deliveryTag,
+ final boolean multiple
+ )
{
- return new BasicAckBodyImpl(
+ return new BasicAckBody(
deliveryTag,
multiple
);
}
public BasicRejectBody createBasicRejectBody(
- final long deliveryTag,
- final boolean requeue
- )
+ final long deliveryTag,
+ final boolean requeue
+ )
{
- return new BasicRejectBodyImpl(
+ return new BasicRejectBody(
deliveryTag,
requeue
);
}
public BasicRecoverBody createBasicRecoverBody(
- final boolean requeue
- )
+ final boolean requeue
+ )
{
- return new BasicRecoverBodyImpl(
+ return new BasicRecoverBody(
requeue
);
}
@@ -872,44 +872,44 @@ public class MethodRegistry_0_9 extends
}
public TxSelectBody createTxSelectBody(
- )
+ )
{
- return new TxSelectBodyImpl(
+ return new TxSelectBody(
);
}
public TxSelectOkBody createTxSelectOkBody(
- )
+ )
{
- return new TxSelectOkBodyImpl(
+ return new TxSelectOkBody(
);
}
public TxCommitBody createTxCommitBody(
- )
+ )
{
- return new TxCommitBodyImpl(
+ return new TxCommitBody(
);
}
public TxCommitOkBody createTxCommitOkBody(
- )
+ )
{
- return new TxCommitOkBodyImpl(
+ return new TxCommitOkBody(
);
}
public TxRollbackBody createTxRollbackBody(
- )
+ )
{
- return new TxRollbackBodyImpl(
+ return new TxRollbackBody(
);
}
public TxRollbackOkBody createTxRollbackOkBody(
- )
+ )
{
- return new TxRollbackOkBodyImpl(
+ return new TxRollbackOkBody(
);
}
Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodConverter_0_91.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodConverter_0_91.java?rev=1628082&r1=1628081&r2=1628082&view=diff
==============================================================================
--- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodConverter_0_91.java (original)
+++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodConverter_0_91.java Sun Sep 28 16:46:34 2014
@@ -24,7 +24,6 @@ package org.apache.qpid.framing.amqp_0_9
import org.apache.qpid.framing.AMQMethodBody;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.framing.BasicPublishBody;
-import org.apache.qpid.framing.BasicPublishBodyImpl;
import org.apache.qpid.framing.abstraction.AbstractMethodConverter;
import org.apache.qpid.framing.abstraction.MessagePublishInfo;
import org.apache.qpid.framing.abstraction.MessagePublishInfoImpl;
@@ -56,7 +55,7 @@ public class MethodConverter_0_91 extend
public AMQMethodBody convertToBody(MessagePublishInfo info)
{
- return new BasicPublishBodyImpl(0,
+ return new BasicPublishBody(0,
info.getExchange(),
info.getRoutingKey(),
info.isMandatory(),
Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java?rev=1628082&r1=1628081&r2=1628082&view=diff
==============================================================================
--- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java (original)
+++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_91/MethodRegistry_0_91.java Sun Sep 28 16:46:34 2014
@@ -62,14 +62,14 @@ public class MethodRegistry_0_91 extends
_factories[10] = new AMQMethodBodyInstanceFactory[52];
- _factories[10][10] = ConnectionStartBodyImpl.getFactory();
- _factories[10][11] = ConnectionStartOkBodyImpl.getFactory();
- _factories[10][20] = ConnectionSecureBodyImpl.getFactory();
- _factories[10][21] = ConnectionSecureOkBodyImpl.getFactory();
- _factories[10][30] = ConnectionTuneBodyImpl.getFactory();
- _factories[10][31] = ConnectionTuneOkBodyImpl.getFactory();
- _factories[10][40] = ConnectionOpenBodyImpl.getFactory();
- _factories[10][41] = ConnectionOpenOkBodyImpl.getFactory();
+ _factories[10][10] = ConnectionStartBody.getFactory();
+ _factories[10][11] = ConnectionStartOkBody.getFactory();
+ _factories[10][20] = ConnectionSecureBody.getFactory();
+ _factories[10][21] = ConnectionSecureOkBody.getFactory();
+ _factories[10][30] = ConnectionTuneBody.getFactory();
+ _factories[10][31] = ConnectionTuneOkBody.getFactory();
+ _factories[10][40] = ConnectionOpenBody.getFactory();
+ _factories[10][41] = ConnectionOpenOkBody.getFactory();
_factories[10][50] = ConnectionCloseBodyImpl.getFactory();
_factories[10][51] = ConnectionCloseOkBodyImpl.getFactory();
@@ -79,12 +79,12 @@ public class MethodRegistry_0_91 extends
_factories[20] = new AMQMethodBodyInstanceFactory[42];
- _factories[20][10] = ChannelOpenBodyImpl.getFactory();
+ _factories[20][10] = ChannelOpenBody.getFactory();
_factories[20][11] = ChannelOpenOkBodyImpl.getFactory();
- _factories[20][20] = ChannelFlowBodyImpl.getFactory();
- _factories[20][21] = ChannelFlowOkBodyImpl.getFactory();
- _factories[20][40] = ChannelCloseBodyImpl.getFactory();
- _factories[20][41] = ChannelCloseOkBodyImpl.getFactory();
+ _factories[20][20] = ChannelFlowBody.getFactory();
+ _factories[20][21] = ChannelFlowOkBody.getFactory();
+ _factories[20][40] = ChannelCloseBody.getFactory();
+ _factories[20][41] = ChannelCloseOkBody.getFactory();
@@ -92,12 +92,12 @@ public class MethodRegistry_0_91 extends
_factories[40] = new AMQMethodBodyInstanceFactory[24];
- _factories[40][10] = ExchangeDeclareBodyImpl.getFactory();
- _factories[40][11] = ExchangeDeclareOkBodyImpl.getFactory();
- _factories[40][20] = ExchangeDeleteBodyImpl.getFactory();
- _factories[40][21] = ExchangeDeleteOkBodyImpl.getFactory();
- _factories[40][22] = ExchangeBoundBodyImpl.getFactory();
- _factories[40][23] = ExchangeBoundOkBodyImpl.getFactory();
+ _factories[40][10] = ExchangeDeclareBody.getFactory();
+ _factories[40][11] = ExchangeDeclareOkBody.getFactory();
+ _factories[40][20] = ExchangeDeleteBody.getFactory();
+ _factories[40][21] = ExchangeDeleteOkBody.getFactory();
+ _factories[40][22] = ExchangeBoundBody.getFactory();
+ _factories[40][23] = ExchangeBoundOkBody.getFactory();
@@ -105,14 +105,14 @@ public class MethodRegistry_0_91 extends
_factories[50] = new AMQMethodBodyInstanceFactory[52];
- _factories[50][10] = QueueDeclareBodyImpl.getFactory();
- _factories[50][11] = QueueDeclareOkBodyImpl.getFactory();
- _factories[50][20] = QueueBindBodyImpl.getFactory();
- _factories[50][21] = QueueBindOkBodyImpl.getFactory();
- _factories[50][30] = QueuePurgeBodyImpl.getFactory();
- _factories[50][31] = QueuePurgeOkBodyImpl.getFactory();
- _factories[50][40] = QueueDeleteBodyImpl.getFactory();
- _factories[50][41] = QueueDeleteOkBodyImpl.getFactory();
+ _factories[50][10] = QueueDeclareBody.getFactory();
+ _factories[50][11] = QueueDeclareOkBody.getFactory();
+ _factories[50][20] = QueueBindBody.getFactory();
+ _factories[50][21] = QueueBindOkBody.getFactory();
+ _factories[50][30] = QueuePurgeBody.getFactory();
+ _factories[50][31] = QueuePurgeOkBody.getFactory();
+ _factories[50][40] = QueueDeleteBody.getFactory();
+ _factories[50][41] = QueueDeleteOkBody.getFactory();
_factories[50][50] = QueueUnbindBodyImpl.getFactory();
_factories[50][51] = QueueUnbindOkBodyImpl.getFactory();
@@ -122,21 +122,21 @@ public class MethodRegistry_0_91 extends
_factories[60] = new AMQMethodBodyInstanceFactory[112];
- _factories[60][10] = BasicQosBodyImpl.getFactory();
- _factories[60][11] = BasicQosOkBodyImpl.getFactory();
- _factories[60][20] = BasicConsumeBodyImpl.getFactory();
- _factories[60][21] = BasicConsumeOkBodyImpl.getFactory();
- _factories[60][30] = BasicCancelBodyImpl.getFactory();
- _factories[60][31] = BasicCancelOkBodyImpl.getFactory();
- _factories[60][40] = BasicPublishBodyImpl.getFactory();
- _factories[60][50] = BasicReturnBodyImpl.getFactory();
- _factories[60][60] = BasicDeliverBodyImpl.getFactory();
- _factories[60][70] = BasicGetBodyImpl.getFactory();
- _factories[60][71] = BasicGetOkBodyImpl.getFactory();
- _factories[60][72] = BasicGetEmptyBodyImpl.getFactory();
- _factories[60][80] = BasicAckBodyImpl.getFactory();
- _factories[60][90] = BasicRejectBodyImpl.getFactory();
- _factories[60][100] = BasicRecoverBodyImpl.getFactory();
+ _factories[60][10] = BasicQosBody.getFactory();
+ _factories[60][11] = BasicQosOkBody.getFactory();
+ _factories[60][20] = BasicConsumeBody.getFactory();
+ _factories[60][21] = BasicConsumeOkBody.getFactory();
+ _factories[60][30] = BasicCancelBody.getFactory();
+ _factories[60][31] = BasicCancelOkBody.getFactory();
+ _factories[60][40] = BasicPublishBody.getFactory();
+ _factories[60][50] = BasicReturnBody.getFactory();
+ _factories[60][60] = BasicDeliverBody.getFactory();
+ _factories[60][70] = BasicGetBody.getFactory();
+ _factories[60][71] = BasicGetOkBody.getFactory();
+ _factories[60][72] = BasicGetEmptyBody.getFactory();
+ _factories[60][80] = BasicAckBody.getFactory();
+ _factories[60][90] = BasicRejectBody.getFactory();
+ _factories[60][100] = BasicRecoverBody.getFactory();
_factories[60][110] = BasicRecoverSyncBodyImpl.getFactory();
_factories[60][111] = BasicRecoverSyncOkBodyImpl.getFactory();
@@ -146,12 +146,12 @@ public class MethodRegistry_0_91 extends
_factories[90] = new AMQMethodBodyInstanceFactory[32];
- _factories[90][10] = TxSelectBodyImpl.getFactory();
- _factories[90][11] = TxSelectOkBodyImpl.getFactory();
- _factories[90][20] = TxCommitBodyImpl.getFactory();
- _factories[90][21] = TxCommitOkBodyImpl.getFactory();
- _factories[90][30] = TxRollbackBodyImpl.getFactory();
- _factories[90][31] = TxRollbackOkBodyImpl.getFactory();
+ _factories[90][10] = TxSelectBody.getFactory();
+ _factories[90][11] = TxSelectOkBody.getFactory();
+ _factories[90][20] = TxCommitBody.getFactory();
+ _factories[90][21] = TxCommitOkBody.getFactory();
+ _factories[90][30] = TxRollbackBody.getFactory();
+ _factories[90][31] = TxRollbackOkBody.getFactory();
}
public AMQMethodBody convertToBody(MarkableDataInput in, long size)
@@ -212,14 +212,14 @@ public class MethodRegistry_0_91 extends
public ConnectionStartBody createConnectionStartBody(
- final short versionMajor,
- final short versionMinor,
- final FieldTable serverProperties,
- final byte[] mechanisms,
- final byte[] locales
- )
+ final short versionMajor,
+ final short versionMinor,
+ final FieldTable serverProperties,
+ final byte[] mechanisms,
+ final byte[] locales
+ )
{
- return new ConnectionStartBodyImpl(
+ return new ConnectionStartBody(
versionMajor,
versionMinor,
serverProperties,
@@ -229,13 +229,13 @@ public class MethodRegistry_0_91 extends
}
public ConnectionStartOkBody createConnectionStartOkBody(
- final FieldTable clientProperties,
- final AMQShortString mechanism,
- final byte[] response,
- final AMQShortString locale
- )
+ final FieldTable clientProperties,
+ final AMQShortString mechanism,
+ final byte[] response,
+ final AMQShortString locale
+ )
{
- return new ConnectionStartOkBodyImpl(
+ return new ConnectionStartOkBody(
clientProperties,
mechanism,
response,
@@ -244,30 +244,30 @@ public class MethodRegistry_0_91 extends
}
public ConnectionSecureBody createConnectionSecureBody(
- final byte[] challenge
- )
+ final byte[] challenge
+ )
{
- return new ConnectionSecureBodyImpl(
+ return new ConnectionSecureBody(
challenge
);
}
public ConnectionSecureOkBody createConnectionSecureOkBody(
- final byte[] response
- )
+ final byte[] response
+ )
{
- return new ConnectionSecureOkBodyImpl(
+ return new ConnectionSecureOkBody(
response
);
}
public ConnectionTuneBody createConnectionTuneBody(
- final int channelMax,
- final long frameMax,
- final int heartbeat
- )
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ )
{
- return new ConnectionTuneBodyImpl(
+ return new ConnectionTuneBody(
channelMax,
frameMax,
heartbeat
@@ -275,12 +275,12 @@ public class MethodRegistry_0_91 extends
}
public ConnectionTuneOkBody createConnectionTuneOkBody(
- final int channelMax,
- final long frameMax,
- final int heartbeat
- )
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ )
{
- return new ConnectionTuneOkBodyImpl(
+ return new ConnectionTuneOkBody(
channelMax,
frameMax,
heartbeat
@@ -288,12 +288,12 @@ public class MethodRegistry_0_91 extends
}
public ConnectionOpenBody createConnectionOpenBody(
- final AMQShortString virtualHost,
- final AMQShortString capabilities,
- final boolean insist
- )
+ final AMQShortString virtualHost,
+ final AMQShortString capabilities,
+ final boolean insist
+ )
{
- return new ConnectionOpenBodyImpl(
+ return new ConnectionOpenBody(
virtualHost,
capabilities,
insist
@@ -301,10 +301,10 @@ public class MethodRegistry_0_91 extends
}
public ConnectionOpenOkBody createConnectionOpenOkBody(
- final AMQShortString knownHosts
- )
+ final AMQShortString knownHosts
+ )
{
- return new ConnectionOpenOkBodyImpl(
+ return new ConnectionOpenOkBody(
knownHosts
);
}
@@ -335,10 +335,10 @@ public class MethodRegistry_0_91 extends
public ChannelOpenBody createChannelOpenBody(
- final AMQShortString outOfBand
- )
+ final AMQShortString outOfBand
+ )
{
- return new ChannelOpenBodyImpl(
+ return new ChannelOpenBody(
outOfBand
);
}
@@ -353,31 +353,31 @@ public class MethodRegistry_0_91 extends
}
public ChannelFlowBody createChannelFlowBody(
- final boolean active
- )
+ final boolean active
+ )
{
- return new ChannelFlowBodyImpl(
+ return new ChannelFlowBody(
active
);
}
public ChannelFlowOkBody createChannelFlowOkBody(
- final boolean active
- )
+ final boolean active
+ )
{
- return new ChannelFlowOkBodyImpl(
+ return new ChannelFlowOkBody(
active
);
}
public ChannelCloseBody createChannelCloseBody(
- final int replyCode,
- final AMQShortString replyText,
- final int classId,
- final int methodId
- )
+ final int replyCode,
+ final AMQShortString replyText,
+ final int classId,
+ final int methodId
+ )
{
- return new ChannelCloseBodyImpl(
+ return new ChannelCloseBody(
replyCode,
replyText,
classId,
@@ -386,9 +386,9 @@ public class MethodRegistry_0_91 extends
}
public ChannelCloseOkBody createChannelCloseOkBody(
- )
+ )
{
- return new ChannelCloseOkBodyImpl(
+ return new ChannelCloseOkBody(
);
}
@@ -396,18 +396,18 @@ public class MethodRegistry_0_91 extends
public ExchangeDeclareBody createExchangeDeclareBody(
- final int ticket,
- final AMQShortString exchange,
- final AMQShortString type,
- final boolean passive,
- final boolean durable,
- final boolean autoDelete,
- final boolean internal,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString type,
+ final boolean passive,
+ final boolean durable,
+ final boolean autoDelete,
+ final boolean internal,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new ExchangeDeclareBodyImpl(
+ return new ExchangeDeclareBody(
ticket,
exchange,
type,
@@ -421,20 +421,20 @@ public class MethodRegistry_0_91 extends
}
public ExchangeDeclareOkBody createExchangeDeclareOkBody(
- )
+ )
{
- return new ExchangeDeclareOkBodyImpl(
+ return new ExchangeDeclareOkBody(
);
}
public ExchangeDeleteBody createExchangeDeleteBody(
- final int ticket,
- final AMQShortString exchange,
- final boolean ifUnused,
- final boolean nowait
- )
+ final int ticket,
+ final AMQShortString exchange,
+ final boolean ifUnused,
+ final boolean nowait
+ )
{
- return new ExchangeDeleteBodyImpl(
+ return new ExchangeDeleteBody(
ticket,
exchange,
ifUnused,
@@ -443,19 +443,19 @@ public class MethodRegistry_0_91 extends
}
public ExchangeDeleteOkBody createExchangeDeleteOkBody(
- )
+ )
{
- return new ExchangeDeleteOkBodyImpl(
+ return new ExchangeDeleteOkBody(
);
}
public ExchangeBoundBody createExchangeBoundBody(
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final AMQShortString queue
- )
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final AMQShortString queue
+ )
{
- return new ExchangeBoundBodyImpl(
+ return new ExchangeBoundBody(
exchange,
routingKey,
queue
@@ -463,11 +463,11 @@ public class MethodRegistry_0_91 extends
}
public ExchangeBoundOkBody createExchangeBoundOkBody(
- final int replyCode,
- final AMQShortString replyText
- )
+ final int replyCode,
+ final AMQShortString replyText
+ )
{
- return new ExchangeBoundOkBodyImpl(
+ return new ExchangeBoundOkBody(
replyCode,
replyText
);
@@ -477,17 +477,17 @@ public class MethodRegistry_0_91 extends
public QueueDeclareBody createQueueDeclareBody(
- final int ticket,
- final AMQShortString queue,
- final boolean passive,
- final boolean durable,
- final boolean exclusive,
- final boolean autoDelete,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean passive,
+ final boolean durable,
+ final boolean exclusive,
+ final boolean autoDelete,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new QueueDeclareBodyImpl(
+ return new QueueDeclareBody(
ticket,
queue,
passive,
@@ -500,12 +500,12 @@ public class MethodRegistry_0_91 extends
}
public QueueDeclareOkBody createQueueDeclareOkBody(
- final AMQShortString queue,
- final long messageCount,
- final long consumerCount
- )
+ final AMQShortString queue,
+ final long messageCount,
+ final long consumerCount
+ )
{
- return new QueueDeclareOkBodyImpl(
+ return new QueueDeclareOkBody(
queue,
messageCount,
consumerCount
@@ -513,15 +513,15 @@ public class MethodRegistry_0_91 extends
}
public QueueBindBody createQueueBindBody(
- final int ticket,
- final AMQShortString queue,
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new QueueBindBodyImpl(
+ return new QueueBindBody(
ticket,
queue,
exchange,
@@ -532,19 +532,19 @@ public class MethodRegistry_0_91 extends
}
public QueueBindOkBody createQueueBindOkBody(
- )
+ )
{
- return new QueueBindOkBodyImpl(
+ return new QueueBindOkBody(
);
}
public QueuePurgeBody createQueuePurgeBody(
- final int ticket,
- final AMQShortString queue,
- final boolean nowait
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean nowait
+ )
{
- return new QueuePurgeBodyImpl(
+ return new QueuePurgeBody(
ticket,
queue,
nowait
@@ -552,23 +552,23 @@ public class MethodRegistry_0_91 extends
}
public QueuePurgeOkBody createQueuePurgeOkBody(
- final long messageCount
- )
+ final long messageCount
+ )
{
- return new QueuePurgeOkBodyImpl(
+ return new QueuePurgeOkBody(
messageCount
);
}
public QueueDeleteBody createQueueDeleteBody(
- final int ticket,
- final AMQShortString queue,
- final boolean ifUnused,
- final boolean ifEmpty,
- final boolean nowait
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean ifUnused,
+ final boolean ifEmpty,
+ final boolean nowait
+ )
{
- return new QueueDeleteBodyImpl(
+ return new QueueDeleteBody(
ticket,
queue,
ifUnused,
@@ -578,10 +578,10 @@ public class MethodRegistry_0_91 extends
}
public QueueDeleteOkBody createQueueDeleteOkBody(
- final long messageCount
- )
+ final long messageCount
+ )
{
- return new QueueDeleteOkBodyImpl(
+ return new QueueDeleteOkBody(
messageCount
);
}
@@ -614,12 +614,12 @@ public class MethodRegistry_0_91 extends
public BasicQosBody createBasicQosBody(
- final long prefetchSize,
- final int prefetchCount,
- final boolean global
- )
+ final long prefetchSize,
+ final int prefetchCount,
+ final boolean global
+ )
{
- return new BasicQosBodyImpl(
+ return new BasicQosBody(
prefetchSize,
prefetchCount,
global
@@ -627,24 +627,24 @@ public class MethodRegistry_0_91 extends
}
public BasicQosOkBody createBasicQosOkBody(
- )
+ )
{
- return new BasicQosOkBodyImpl(
+ return new BasicQosOkBody(
);
}
public BasicConsumeBody createBasicConsumeBody(
- final int ticket,
- final AMQShortString queue,
- final AMQShortString consumerTag,
- final boolean noLocal,
- final boolean noAck,
- final boolean exclusive,
- final boolean nowait,
- final FieldTable arguments
- )
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString consumerTag,
+ final boolean noLocal,
+ final boolean noAck,
+ final boolean exclusive,
+ final boolean nowait,
+ final FieldTable arguments
+ )
{
- return new BasicConsumeBodyImpl(
+ return new BasicConsumeBody(
ticket,
queue,
consumerTag,
@@ -657,43 +657,43 @@ public class MethodRegistry_0_91 extends
}
public BasicConsumeOkBody createBasicConsumeOkBody(
- final AMQShortString consumerTag
- )
+ final AMQShortString consumerTag
+ )
{
- return new BasicConsumeOkBodyImpl(
+ return new BasicConsumeOkBody(
consumerTag
);
}
public BasicCancelBody createBasicCancelBody(
- final AMQShortString consumerTag,
- final boolean nowait
- )
+ final AMQShortString consumerTag,
+ final boolean nowait
+ )
{
- return new BasicCancelBodyImpl(
+ return new BasicCancelBody(
consumerTag,
nowait
);
}
public BasicCancelOkBody createBasicCancelOkBody(
- final AMQShortString consumerTag
- )
+ final AMQShortString consumerTag
+ )
{
- return new BasicCancelOkBodyImpl(
+ return new BasicCancelOkBody(
consumerTag
);
}
public BasicPublishBody createBasicPublishBody(
- final int ticket,
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final boolean mandatory,
- final boolean immediate
- )
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean mandatory,
+ final boolean immediate
+ )
{
- return new BasicPublishBodyImpl(
+ return new BasicPublishBody(
ticket,
exchange,
routingKey,
@@ -703,13 +703,13 @@ public class MethodRegistry_0_91 extends
}
public BasicReturnBody createBasicReturnBody(
- final int replyCode,
- final AMQShortString replyText,
- final AMQShortString exchange,
- final AMQShortString routingKey
- )
+ final int replyCode,
+ final AMQShortString replyText,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ )
{
- return new BasicReturnBodyImpl(
+ return new BasicReturnBody(
replyCode,
replyText,
exchange,
@@ -718,14 +718,14 @@ public class MethodRegistry_0_91 extends
}
public BasicDeliverBody createBasicDeliverBody(
- final AMQShortString consumerTag,
- final long deliveryTag,
- final boolean redelivered,
- final AMQShortString exchange,
- final AMQShortString routingKey
- )
+ final AMQShortString consumerTag,
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ )
{
- return new BasicDeliverBodyImpl(
+ return new BasicDeliverBody(
consumerTag,
deliveryTag,
redelivered,
@@ -735,12 +735,12 @@ public class MethodRegistry_0_91 extends
}
public BasicGetBody createBasicGetBody(
- final int ticket,
- final AMQShortString queue,
- final boolean noAck
- )
+ final int ticket,
+ final AMQShortString queue,
+ final boolean noAck
+ )
{
- return new BasicGetBodyImpl(
+ return new BasicGetBody(
ticket,
queue,
noAck
@@ -748,14 +748,14 @@ public class MethodRegistry_0_91 extends
}
public BasicGetOkBody createBasicGetOkBody(
- final long deliveryTag,
- final boolean redelivered,
- final AMQShortString exchange,
- final AMQShortString routingKey,
- final long messageCount
- )
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final long messageCount
+ )
{
- return new BasicGetOkBodyImpl(
+ return new BasicGetOkBody(
deliveryTag,
redelivered,
exchange,
@@ -765,41 +765,41 @@ public class MethodRegistry_0_91 extends
}
public BasicGetEmptyBody createBasicGetEmptyBody(
- final AMQShortString clusterId
- )
+ final AMQShortString clusterId
+ )
{
- return new BasicGetEmptyBodyImpl(
+ return new BasicGetEmptyBody(
clusterId
);
}
public BasicAckBody createBasicAckBody(
- final long deliveryTag,
- final boolean multiple
- )
+ final long deliveryTag,
+ final boolean multiple
+ )
{
- return new BasicAckBodyImpl(
+ return new BasicAckBody(
deliveryTag,
multiple
);
}
public BasicRejectBody createBasicRejectBody(
- final long deliveryTag,
- final boolean requeue
- )
+ final long deliveryTag,
+ final boolean requeue
+ )
{
- return new BasicRejectBodyImpl(
+ return new BasicRejectBody(
deliveryTag,
requeue
);
}
public BasicRecoverBody createBasicRecoverBody(
- final boolean requeue
- )
+ final boolean requeue
+ )
{
- return new BasicRecoverBodyImpl(
+ return new BasicRecoverBody(
requeue
);
}
@@ -824,44 +824,44 @@ public class MethodRegistry_0_91 extends
public TxSelectBody createTxSelectBody(
- )
+ )
{
- return new TxSelectBodyImpl(
+ return new TxSelectBody(
);
}
public TxSelectOkBody createTxSelectOkBody(
- )
+ )
{
- return new TxSelectOkBodyImpl(
+ return new TxSelectOkBody(
);
}
public TxCommitBody createTxCommitBody(
- )
+ )
{
- return new TxCommitBodyImpl(
+ return new TxCommitBody(
);
}
public TxCommitOkBody createTxCommitOkBody(
- )
+ )
{
- return new TxCommitOkBodyImpl(
+ return new TxCommitOkBody(
);
}
public TxRollbackBody createTxRollbackBody(
- )
+ )
{
- return new TxRollbackBodyImpl(
+ return new TxRollbackBody(
);
}
public TxRollbackOkBody createTxRollbackOkBody(
- )
+ )
{
- return new TxRollbackOkBodyImpl(
+ return new TxRollbackOkBody(
);
}
Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/MethodConverter_8_0.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/MethodConverter_8_0.java?rev=1628082&r1=1628081&r2=1628082&view=diff
==============================================================================
--- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/MethodConverter_8_0.java (original)
+++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/MethodConverter_8_0.java Sun Sep 28 16:46:34 2014
@@ -24,7 +24,6 @@ package org.apache.qpid.framing.amqp_8_0
import org.apache.qpid.framing.AMQMethodBody;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.framing.BasicPublishBody;
-import org.apache.qpid.framing.BasicPublishBodyImpl;
import org.apache.qpid.framing.abstraction.AbstractMethodConverter;
import org.apache.qpid.framing.abstraction.MessagePublishInfo;
import org.apache.qpid.framing.abstraction.MessagePublishInfoImpl;
@@ -55,7 +54,7 @@ public class MethodConverter_8_0 extends
public AMQMethodBody convertToBody(MessagePublishInfo info)
{
- return new BasicPublishBodyImpl(0,
+ return new BasicPublishBody(0,
info.getExchange(),
info.getRoutingKey(),
info.isMandatory(),
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org