diff --git a/kombu/tests/mocks.py b/kombu/tests/mocks.py index dfcff423..eca0ab45 100644 --- a/kombu/tests/mocks.py +++ b/kombu/tests/mocks.py @@ -17,7 +17,7 @@ class Message(base.Message): return super(Message, self).decode() -class Channel(object): +class Channel(base.StdChannel): open = True throw_decode_error = False diff --git a/kombu/transport/memory.py b/kombu/transport/memory.py index 7553a9fd..35907e35 100644 --- a/kombu/transport/memory.py +++ b/kombu/transport/memory.py @@ -41,6 +41,9 @@ class Channel(virtual.Channel): self.queues[queue].queue.clear() return size + def after_reply_message_received(self, queue): + pass + class Transport(virtual.Transport): Channel = Channel