Memory transport does support fanout

This commit is contained in:
Ask Solem 2016-07-25 21:02:04 -07:00
parent 88f97d1538
commit f58639708b
1 changed files with 3 additions and 0 deletions

View File

@ -3,6 +3,7 @@ from __future__ import absolute_import, unicode_literals
from kombu.five import Queue, values
from . import base
from . import virtual
@ -64,6 +65,8 @@ class Transport(virtual.Transport):
#: memory backend state is global.
state = virtual.BrokerState()
implements = base.Transport.implements
driver_type = 'memory'
driver_name = 'memory'