mirror of https://github.com/celery/kombu.git
Tests passing
This commit is contained in:
parent
9f00ccdcc8
commit
8537a359f6
|
@ -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
|
||||
|
||||
|
|
|
@ -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
|
||||
|
|
Loading…
Reference in New Issue