From f58639708bca566938369095174394bfd73b13c8 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Mon, 25 Jul 2016 21:02:04 -0700 Subject: [PATCH] Memory transport does support fanout --- kombu/transport/memory.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/kombu/transport/memory.py b/kombu/transport/memory.py index 002b2e73..419212f3 100644 --- a/kombu/transport/memory.py +++ b/kombu/transport/memory.py @@ -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'