summaryrefslogtreecommitdiff
path: root/cpp/lib/common/framing/AMQMethodBody.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/common/framing/AMQMethodBody.cpp')
-rw-r--r--cpp/lib/common/framing/AMQMethodBody.cpp8
1 files changed, 2 insertions, 6 deletions
diff --git a/cpp/lib/common/framing/AMQMethodBody.cpp b/cpp/lib/common/framing/AMQMethodBody.cpp
index 73b729b945..17138a401e 100644
--- a/cpp/lib/common/framing/AMQMethodBody.cpp
+++ b/cpp/lib/common/framing/AMQMethodBody.cpp
@@ -31,10 +31,6 @@ void AMQMethodBody::encodeId(Buffer& buffer) const{
buffer.putShort(amqpMethodId());
}
-bool AMQMethodBody::match(AMQMethodBody* other) const{
- return other != 0 && other->amqpClassId() == amqpClassId() && other->amqpMethodId() == amqpMethodId();
-}
-
void AMQMethodBody::invoke(AMQP_ServerOperations&, const MethodContext&){
assert(0);
THROW_QPID_ERROR(PROTOCOL_ERROR, "Method not supported by AMQP Server.");
@@ -44,14 +40,14 @@ AMQMethodBody::shared_ptr AMQMethodBody::create(
AMQP_MethodVersionMap& versionMap, ProtocolVersion version,
Buffer& buffer)
{
- MethodId id;
+ ClassMethodId id;
id.decode(buffer);
return AMQMethodBody::shared_ptr(
versionMap.createMethodBody(
id.classId, id.methodId, version.getMajor(), version.getMinor()));
}
-void AMQMethodBody::MethodId::decode(Buffer& buffer) {
+void AMQMethodBody::ClassMethodId::decode(Buffer& buffer) {
classId = buffer.getShort();
methodId = buffer.getShort();
}