Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ConnectionSecureBodyImpl extends AMQMethodBodyImpl implements ConnectionSecureBody +public class ConnectionSecureBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ConnectionSecureBodyImpl(in); + return new ConnectionSecureBody(in); } }; @@ -55,14 +55,14 @@ public class ConnectionSecureBodyImpl ex private final byte[] _challenge; // [challenge] // Constructor - public ConnectionSecureBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ConnectionSecureBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _challenge = readBytes( buffer ); } - public ConnectionSecureBodyImpl( - byte[] challenge - ) + public ConnectionSecureBody( + byte[] challenge + ) { _challenge = challenge; }
Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionSecureOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ConnectionSecureOkBodyImpl extends AMQMethodBodyImpl implements ConnectionSecureOkBody +public class ConnectionSecureOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ConnectionSecureOkBodyImpl(in); + return new ConnectionSecureOkBody(in); } }; @@ -55,14 +55,14 @@ public class ConnectionSecureOkBodyImpl private final byte[] _response; // [response] // Constructor - public ConnectionSecureOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ConnectionSecureOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _response = readBytes( buffer ); } - public ConnectionSecureOkBodyImpl( - byte[] response - ) + public ConnectionSecureOkBody( + byte[] response + ) { _response = response; } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ConnectionStartBodyImpl extends AMQMethodBodyImpl implements ConnectionStartBody +public class ConnectionStartBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ConnectionStartBodyImpl(in); + return new ConnectionStartBody(in); } }; @@ -59,7 +59,7 @@ public class ConnectionStartBodyImpl ext private final byte[] _locales; // [locales] // Constructor - public ConnectionStartBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ConnectionStartBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _versionMajor = readUnsignedByte( buffer ); _versionMinor = readUnsignedByte( buffer ); @@ -68,13 +68,13 @@ public class ConnectionStartBodyImpl ext _locales = readBytes( buffer ); } - public ConnectionStartBodyImpl( - short versionMajor, - short versionMinor, - FieldTable serverProperties, - byte[] mechanisms, - byte[] locales - ) + public ConnectionStartBody( + short versionMajor, + short versionMinor, + FieldTable serverProperties, + byte[] mechanisms, + byte[] locales + ) { _versionMajor = versionMajor; _versionMinor = versionMinor; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ConnectionStartOkBodyImpl extends AMQMethodBodyImpl implements ConnectionStartOkBody +public class ConnectionStartOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ConnectionStartOkBodyImpl(in); + return new ConnectionStartOkBody(in); } }; @@ -58,7 +58,7 @@ public class ConnectionStartOkBodyImpl e private final AMQShortString _locale; // [locale] // Constructor - public ConnectionStartOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ConnectionStartOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _clientProperties = readFieldTable( buffer ); _mechanism = readAMQShortString( buffer ); @@ -66,12 +66,12 @@ public class ConnectionStartOkBodyImpl e _locale = readAMQShortString( buffer ); } - public ConnectionStartOkBodyImpl( - FieldTable clientProperties, - AMQShortString mechanism, - byte[] response, - AMQShortString locale - ) + public ConnectionStartOkBody( + FieldTable clientProperties, + AMQShortString mechanism, + byte[] response, + AMQShortString locale + ) { _clientProperties = clientProperties; _mechanism = mechanism; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ConnectionTuneBodyImpl extends AMQMethodBodyImpl implements ConnectionTuneBody +public class ConnectionTuneBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ConnectionTuneBodyImpl(in); + return new ConnectionTuneBody(in); } }; @@ -57,18 +57,18 @@ public class ConnectionTuneBodyImpl exte private final int _heartbeat; // [heartbeat] // Constructor - public ConnectionTuneBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ConnectionTuneBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _channelMax = readUnsignedShort( buffer ); _frameMax = readUnsignedInteger( buffer ); _heartbeat = readUnsignedShort( buffer ); } - public ConnectionTuneBodyImpl( - int channelMax, - long frameMax, - int heartbeat - ) + public ConnectionTuneBody( + int channelMax, + long frameMax, + int heartbeat + ) { _channelMax = channelMax; _frameMax = frameMax; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ConnectionTuneOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ConnectionTuneOkBodyImpl extends AMQMethodBodyImpl implements ConnectionTuneOkBody +public class ConnectionTuneOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ConnectionTuneOkBodyImpl(in); + return new ConnectionTuneOkBody(in); } }; @@ -57,18 +57,18 @@ public class ConnectionTuneOkBodyImpl ex private final int _heartbeat; // [heartbeat] // Constructor - public ConnectionTuneOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ConnectionTuneOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _channelMax = readUnsignedShort( buffer ); _frameMax = readUnsignedInteger( buffer ); _heartbeat = readUnsignedShort( buffer ); } - public ConnectionTuneOkBodyImpl( - int channelMax, - long frameMax, - int heartbeat - ) + public ConnectionTuneOkBody( + int channelMax, + long frameMax, + int heartbeat + ) { _channelMax = channelMax; _frameMax = frameMax; Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderPropertiesFactory.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderPropertiesFactory.java?rev=1628082&r1=1628081&r2=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderPropertiesFactory.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderPropertiesFactory.java Sun Sep 28 16:46:34 2014 @@ -44,7 +44,7 @@ public class ContentHeaderPropertiesFact // AMQP version change: "Hardwired" version to major=8, minor=0 // TODO: Change so that the actual version is obtained from // the ProtocolInitiation object for this session. - if (classId == BasicConsumeBodyImpl.CLASS_ID) + if (classId == BasicConsumeBody.CLASS_ID) { properties = new BasicContentHeaderProperties(); } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeBoundBodyImpl extends AMQMethodBodyImpl implements ExchangeBoundBody +public class ExchangeBoundBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ExchangeBoundBodyImpl(in); + return new ExchangeBoundBody(in); } }; @@ -57,17 +57,17 @@ public class ExchangeBoundBodyImpl exten private final AMQShortString _queue; // [queue] // Constructor - public ExchangeBoundBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ExchangeBoundBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _exchange = readAMQShortString( buffer ); _routingKey = readAMQShortString( buffer ); _queue = readAMQShortString( buffer ); } - public ExchangeBoundBodyImpl( - AMQShortString exchange, - AMQShortString routingKey, - AMQShortString queue + public ExchangeBoundBody( + AMQShortString exchange, + AMQShortString routingKey, + AMQShortString queue ) { _exchange = exchange; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeBoundOkBodyImpl extends AMQMethodBodyImpl implements ExchangeBoundOkBody +public class ExchangeBoundOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ExchangeBoundOkBodyImpl(in); + return new ExchangeBoundOkBody(in); } }; @@ -56,16 +56,16 @@ public class ExchangeBoundOkBodyImpl ext private final AMQShortString _replyText; // [replyText] // Constructor - public ExchangeBoundOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ExchangeBoundOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _replyCode = readUnsignedShort( buffer ); _replyText = readAMQShortString( buffer ); } - public ExchangeBoundOkBodyImpl( - int replyCode, - AMQShortString replyText - ) + public ExchangeBoundOkBody( + int replyCode, + AMQShortString replyText + ) { _replyCode = replyCode; _replyText = replyText; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeclareBodyImpl extends AMQMethodBodyImpl implements ExchangeDeclareBody +public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ExchangeDeclareBodyImpl(in); + return new ExchangeDeclareBody(in); } }; @@ -59,7 +59,7 @@ public class ExchangeDeclareBodyImpl ext private final FieldTable _arguments; // [arguments] // Constructor - public ExchangeDeclareBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ExchangeDeclareBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _ticket = readUnsignedShort( buffer ); _exchange = readAMQShortString( buffer ); @@ -68,17 +68,17 @@ public class ExchangeDeclareBodyImpl ext _arguments = readFieldTable( buffer ); } - public ExchangeDeclareBodyImpl( - int ticket, - AMQShortString exchange, - AMQShortString type, - boolean passive, - boolean durable, - boolean autoDelete, - boolean internal, - boolean nowait, - FieldTable arguments - ) + public ExchangeDeclareBody( + int ticket, + AMQShortString exchange, + AMQShortString type, + boolean passive, + boolean durable, + boolean autoDelete, + boolean internal, + boolean nowait, + FieldTable arguments + ) { _ticket = ticket; _exchange = exchange; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeclareOkBodyImpl extends AMQMethodBodyImpl implements ExchangeDeclareOkBody +public class ExchangeDeclareOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ExchangeDeclareOkBodyImpl(in); + return new ExchangeDeclareOkBody(in); } }; @@ -54,12 +54,12 @@ public class ExchangeDeclareOkBodyImpl e // Fields declared in specification // Constructor - public ExchangeDeclareOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ExchangeDeclareOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public ExchangeDeclareOkBodyImpl( - ) + public ExchangeDeclareOkBody( + ) { } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeleteBodyImpl extends AMQMethodBodyImpl implements ExchangeDeleteBody +public class ExchangeDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ExchangeDeleteBodyImpl(in); + return new ExchangeDeleteBody(in); } }; @@ -57,19 +57,19 @@ public class ExchangeDeleteBodyImpl exte private final byte _bitfield0; // [ifUnused, nowait] // Constructor - public ExchangeDeleteBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ExchangeDeleteBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _ticket = readUnsignedShort( buffer ); _exchange = readAMQShortString( buffer ); _bitfield0 = readBitfield( buffer ); } - public ExchangeDeleteBodyImpl( - int ticket, - AMQShortString exchange, - boolean ifUnused, - boolean nowait - ) + public ExchangeDeleteBody( + int ticket, + AMQShortString exchange, + boolean ifUnused, + boolean nowait + ) { _ticket = ticket; _exchange = exchange; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeleteOkBodyImpl extends AMQMethodBodyImpl implements ExchangeDeleteOkBody +public class ExchangeDeleteOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new ExchangeDeleteOkBodyImpl(in); + return new ExchangeDeleteOkBody(in); } }; @@ -54,12 +54,12 @@ public class ExchangeDeleteOkBodyImpl ex // Fields declared in specification // Constructor - public ExchangeDeleteOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public ExchangeDeleteOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public ExchangeDeleteOkBodyImpl( - ) + public ExchangeDeleteOkBody( + ) { } Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java?rev=1628082&r1=1628081&r2=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java Sun Sep 28 16:46:34 2014 @@ -74,115 +74,115 @@ public abstract class MethodRegistry public abstract BasicAckBody createBasicAckBody( - final long deliveryTag, - final boolean multiple - ); + final long deliveryTag, + final boolean multiple + ); public abstract BasicCancelBody createBasicCancelBody( - final AMQShortString consumerTag, - final boolean nowait - ); + final AMQShortString consumerTag, + final boolean nowait + ); public abstract BasicCancelOkBody createBasicCancelOkBody( - final AMQShortString consumerTag - ); + final AMQShortString consumerTag + ); public abstract 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 + ); public abstract BasicConsumeOkBody createBasicConsumeOkBody( - final AMQShortString consumerTag - ); + final AMQShortString consumerTag + ); public abstract 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 + ); public abstract BasicGetBody createBasicGetBody( - final int ticket, - final AMQShortString queue, - final boolean noAck - ); + final int ticket, + final AMQShortString queue, + final boolean noAck + ); public abstract BasicGetEmptyBody createBasicGetEmptyBody( - final AMQShortString clusterId - ); + final AMQShortString clusterId + ); public abstract 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 + ); public abstract 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 + ); public abstract BasicQosBody createBasicQosBody( - final long prefetchSize, - final int prefetchCount, - final boolean global - ); + final long prefetchSize, + final int prefetchCount, + final boolean global + ); public abstract BasicQosOkBody createBasicQosOkBody( - ); + ); public abstract BasicRecoverBody createBasicRecoverBody( - final boolean requeue - ); + final boolean requeue + ); public abstract BasicRejectBody createBasicRejectBody( - final long deliveryTag, - final boolean requeue - ); + final long deliveryTag, + final boolean requeue + ); public abstract 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 + ); public abstract 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 + ); public abstract ChannelCloseOkBody createChannelCloseOkBody( - ); + ); public abstract ChannelFlowBody createChannelFlowBody( - final boolean active - ); + final boolean active + ); public abstract ChannelFlowOkBody createChannelFlowOkBody( - final boolean active - ); + final boolean active + ); public abstract ChannelOpenBody createChannelOpenBody( - final AMQShortString outOfBand - ); + final AMQShortString outOfBand + ); public abstract ConnectionCloseBody createConnectionCloseBody( @@ -196,163 +196,163 @@ public abstract class MethodRegistry ); public abstract ConnectionOpenBody createConnectionOpenBody( - final AMQShortString virtualHost, - final AMQShortString capabilities, - final boolean insist - ); + final AMQShortString virtualHost, + final AMQShortString capabilities, + final boolean insist + ); public abstract ConnectionOpenOkBody createConnectionOpenOkBody( - final AMQShortString knownHosts - ); + final AMQShortString knownHosts + ); public abstract ConnectionSecureBody createConnectionSecureBody( - final byte[] challenge - ); + final byte[] challenge + ); public abstract ConnectionSecureOkBody createConnectionSecureOkBody( - final byte[] response - ); + final byte[] response + ); public abstract 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 + ); public abstract 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 + ); public abstract ConnectionTuneBody createConnectionTuneBody( - final int channelMax, - final long frameMax, - final int heartbeat - ); + final int channelMax, + final long frameMax, + final int heartbeat + ); public abstract ConnectionTuneOkBody createConnectionTuneOkBody( - final int channelMax, - final long frameMax, - final int heartbeat - ); + final int channelMax, + final long frameMax, + final int heartbeat + ); public abstract ExchangeBoundBody createExchangeBoundBody( - final AMQShortString exchange, - final AMQShortString routingKey, - final AMQShortString queue - ); + final AMQShortString exchange, + final AMQShortString routingKey, + final AMQShortString queue + ); public abstract ExchangeBoundOkBody createExchangeBoundOkBody( - final int replyCode, - final AMQShortString replyText - ); + final int replyCode, + final AMQShortString replyText + ); public abstract 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 + ); public abstract ExchangeDeclareOkBody createExchangeDeclareOkBody( - ); + ); public abstract 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 + ); public abstract ExchangeDeleteOkBody createExchangeDeleteOkBody( - ); + ); public abstract 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 + ); public abstract QueueBindOkBody createQueueBindOkBody( - ); + ); public abstract 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 + ); public abstract QueueDeclareOkBody createQueueDeclareOkBody( - final AMQShortString queue, - final long messageCount, - final long consumerCount - ); + final AMQShortString queue, + final long messageCount, + final long consumerCount + ); public abstract 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 + ); public abstract QueueDeleteOkBody createQueueDeleteOkBody( - final long messageCount - ); + final long messageCount + ); public abstract QueuePurgeBody createQueuePurgeBody( - final int ticket, - final AMQShortString queue, - final boolean nowait - ); + final int ticket, + final AMQShortString queue, + final boolean nowait + ); public abstract QueuePurgeOkBody createQueuePurgeOkBody( - final long messageCount - ); + final long messageCount + ); public abstract TxCommitBody createTxCommitBody( - ); + ); public abstract TxCommitOkBody createTxCommitOkBody( - ); + ); public abstract TxRollbackBody createTxRollbackBody( - ); + ); public abstract TxRollbackOkBody createTxRollbackOkBody( - ); + ); public abstract TxSelectBody createTxSelectBody( - ); + ); public abstract TxSelectOkBody createTxSelectOkBody( - ); + ); public abstract ProtocolVersionMethodConverter getProtocolVersionMethodConverter(); } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueueBindBodyImpl extends AMQMethodBodyImpl implements QueueBindBody +public class QueueBindBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueueBindBodyImpl(in); + return new QueueBindBody(in); } }; @@ -60,7 +60,7 @@ public class QueueBindBodyImpl extends A private final FieldTable _arguments; // [arguments] // Constructor - public QueueBindBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueueBindBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _ticket = readUnsignedShort( buffer ); _queue = readAMQShortString( buffer ); @@ -70,14 +70,14 @@ public class QueueBindBodyImpl extends A _arguments = readFieldTable( buffer ); } - public QueueBindBodyImpl( - int ticket, - AMQShortString queue, - AMQShortString exchange, - AMQShortString routingKey, - boolean nowait, - FieldTable arguments - ) + public QueueBindBody( + int ticket, + AMQShortString queue, + AMQShortString exchange, + AMQShortString routingKey, + boolean nowait, + FieldTable arguments + ) { _ticket = ticket; _queue = queue; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueueBindOkBodyImpl extends AMQMethodBodyImpl implements QueueBindOkBody +public class QueueBindOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueueBindOkBodyImpl(in); + return new QueueBindOkBody(in); } }; @@ -54,12 +54,12 @@ public class QueueBindOkBodyImpl extends // Fields declared in specification // Constructor - public QueueBindOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueueBindOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public QueueBindOkBodyImpl( - ) + public QueueBindOkBody( + ) { } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeclareBodyImpl extends AMQMethodBodyImpl implements QueueDeclareBody +public class QueueDeclareBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueueDeclareBodyImpl(in); + return new QueueDeclareBody(in); } }; @@ -58,7 +58,7 @@ public class QueueDeclareBodyImpl extend private final FieldTable _arguments; // [arguments] // Constructor - public QueueDeclareBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueueDeclareBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _ticket = readUnsignedShort( buffer ); _queue = readAMQShortString( buffer ); @@ -66,16 +66,16 @@ public class QueueDeclareBodyImpl extend _arguments = readFieldTable( buffer ); } - public QueueDeclareBodyImpl( - int ticket, - AMQShortString queue, - boolean passive, - boolean durable, - boolean exclusive, - boolean autoDelete, - boolean nowait, - FieldTable arguments - ) + public QueueDeclareBody( + int ticket, + AMQShortString queue, + boolean passive, + boolean durable, + boolean exclusive, + boolean autoDelete, + boolean nowait, + FieldTable arguments + ) { _ticket = ticket; _queue = queue; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeclareOkBodyImpl extends AMQMethodBodyImpl implements QueueDeclareOkBody +public class QueueDeclareOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueueDeclareOkBodyImpl(in); + return new QueueDeclareOkBody(in); } }; @@ -57,18 +57,18 @@ public class QueueDeclareOkBodyImpl exte private final long _consumerCount; // [consumerCount] // Constructor - public QueueDeclareOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueueDeclareOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _queue = readAMQShortString( buffer ); _messageCount = readUnsignedInteger( buffer ); _consumerCount = readUnsignedInteger( buffer ); } - public QueueDeclareOkBodyImpl( - AMQShortString queue, - long messageCount, - long consumerCount - ) + public QueueDeclareOkBody( + AMQShortString queue, + long messageCount, + long consumerCount + ) { _queue = queue; _messageCount = messageCount; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeleteBodyImpl extends AMQMethodBodyImpl implements QueueDeleteBody +public class QueueDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueueDeleteBodyImpl(in); + return new QueueDeleteBody(in); } }; @@ -57,20 +57,20 @@ public class QueueDeleteBodyImpl extends private final byte _bitfield0; // [ifUnused, ifEmpty, nowait] // Constructor - public QueueDeleteBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueueDeleteBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _ticket = readUnsignedShort( buffer ); _queue = readAMQShortString( buffer ); _bitfield0 = readBitfield( buffer ); } - public QueueDeleteBodyImpl( - int ticket, - AMQShortString queue, - boolean ifUnused, - boolean ifEmpty, - boolean nowait - ) + public QueueDeleteBody( + int ticket, + AMQShortString queue, + boolean ifUnused, + boolean ifEmpty, + boolean nowait + ) { _ticket = ticket; _queue = queue; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeleteOkBodyImpl extends AMQMethodBodyImpl implements QueueDeleteOkBody +public class QueueDeleteOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueueDeleteOkBodyImpl(in); + return new QueueDeleteOkBody(in); } }; @@ -55,13 +55,13 @@ public class QueueDeleteOkBodyImpl exten private final long _messageCount; // [messageCount] // Constructor - public QueueDeleteOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueueDeleteOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _messageCount = readUnsignedInteger( buffer ); } - public QueueDeleteOkBodyImpl( - long messageCount + public QueueDeleteOkBody( + long messageCount ) { _messageCount = messageCount; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueuePurgeBodyImpl extends AMQMethodBodyImpl implements QueuePurgeBody +public class QueuePurgeBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueuePurgeBodyImpl(in); + return new QueuePurgeBody(in); } }; @@ -57,18 +57,18 @@ public class QueuePurgeBodyImpl extends private final byte _bitfield0; // [nowait] // Constructor - public QueuePurgeBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueuePurgeBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _ticket = readUnsignedShort( buffer ); _queue = readAMQShortString( buffer ); _bitfield0 = readBitfield( buffer ); } - public QueuePurgeBodyImpl( - int ticket, - AMQShortString queue, - boolean nowait - ) + public QueuePurgeBody( + int ticket, + AMQShortString queue, + boolean nowait + ) { _ticket = ticket; _queue = queue; Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class QueuePurgeOkBodyImpl extends AMQMethodBodyImpl implements QueuePurgeOkBody +public class QueuePurgeOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new QueuePurgeOkBodyImpl(in); + return new QueuePurgeOkBody(in); } }; @@ -55,14 +55,14 @@ public class QueuePurgeOkBodyImpl extend private final long _messageCount; // [messageCount] // Constructor - public QueuePurgeOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public QueuePurgeOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { _messageCount = readUnsignedInteger( buffer ); } - public QueuePurgeOkBodyImpl( - long messageCount - ) + public QueuePurgeOkBody( + long messageCount + ) { _messageCount = messageCount; } Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java?rev=1628082&r1=1628081&r2=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java Sun Sep 28 16:46:34 2014 @@ -64,4 +64,4 @@ public interface ServerMethodDispatcher public boolean dispatchTxRollback(TxRollbackBody body, int channelId) throws AMQException; public boolean dispatchTxSelect(TxSelectBody body, int channelId) throws AMQException; -} \ No newline at end of file +} Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class TxCommitBodyImpl extends AMQMethodBodyImpl implements TxCommitBody +public class TxCommitBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new TxCommitBodyImpl(in); + return new TxCommitBody(in); } }; @@ -54,12 +54,12 @@ public class TxCommitBodyImpl extends AM // Fields declared in specification // Constructor - public TxCommitBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public TxCommitBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public TxCommitBodyImpl( - ) + public TxCommitBody( + ) { } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class TxCommitOkBodyImpl extends AMQMethodBodyImpl implements TxCommitOkBody +public class TxCommitOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new TxCommitOkBodyImpl(in); + return new TxCommitOkBody(in); } }; @@ -54,12 +54,12 @@ public class TxCommitOkBodyImpl extends // Fields declared in specification // Constructor - public TxCommitOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public TxCommitOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public TxCommitOkBodyImpl( - ) + public TxCommitOkBody( + ) { } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class TxRollbackBodyImpl extends AMQMethodBodyImpl implements TxRollbackBody +public class TxRollbackBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new TxRollbackBodyImpl(in); + return new TxRollbackBody(in); } }; @@ -54,12 +54,12 @@ public class TxRollbackBodyImpl extends // Fields declared in specification // Constructor - public TxRollbackBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public TxRollbackBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public TxRollbackBodyImpl( - ) + public TxRollbackBody( + ) { } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class TxRollbackOkBodyImpl extends AMQMethodBodyImpl implements TxRollbackOkBody +public class TxRollbackOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new TxRollbackOkBodyImpl(in); + return new TxRollbackOkBody(in); } }; @@ -54,12 +54,12 @@ public class TxRollbackOkBodyImpl extend // Fields declared in specification // Constructor - public TxRollbackOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public TxRollbackOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public TxRollbackOkBodyImpl( - ) + public TxRollbackOkBody( + ) { } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class TxSelectBodyImpl extends AMQMethodBodyImpl implements TxSelectBody +public class TxSelectBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new TxSelectBodyImpl(in); + return new TxSelectBody(in); } }; @@ -54,12 +54,12 @@ public class TxSelectBodyImpl extends AM // Fields declared in specification // Constructor - public TxSelectBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public TxSelectBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public TxSelectBodyImpl( - ) + public TxSelectBody( + ) { } Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBody.java (from r1628074, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBody.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBody.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBodyImpl.java&r1=1628074&r2=1628082&rev=1628082&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBody.java Sun Sep 28 16:46:34 2014 @@ -33,13 +33,13 @@ import java.io.IOException; import org.apache.qpid.AMQException; import org.apache.qpid.codec.MarkableDataInput; -public class TxSelectOkBodyImpl extends AMQMethodBodyImpl implements TxSelectOkBody +public class TxSelectOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException { - return new TxSelectOkBodyImpl(in); + return new TxSelectOkBody(in); } }; @@ -54,12 +54,12 @@ public class TxSelectOkBodyImpl extends // Fields declared in specification // Constructor - public TxSelectOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + public TxSelectOkBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException { } - public TxSelectOkBodyImpl( - ) + public TxSelectOkBody( + ) { } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
