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 [2/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/...
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org