diff options
Diffstat (limited to 'cpp/lib/common/framing/AMQMethodBody.cpp')
-rw-r--r-- | cpp/lib/common/framing/AMQMethodBody.cpp | 8 |
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(); } |