diff options
Diffstat (limited to 'kombu/transport/virtual/exchange.py')
| -rw-r--r-- | kombu/transport/virtual/exchange.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/transport/virtual/exchange.py b/kombu/transport/virtual/exchange.py index 51909a1d..4f9e4fb7 100644 --- a/kombu/transport/virtual/exchange.py +++ b/kombu/transport/virtual/exchange.py @@ -65,7 +65,7 @@ class DirectExchange(ExchangeType): } def deliver(self, message, exchange, routing_key, **kwargs): - _lookup = self.channel._lookup + _lookup = self.channel._lookup_direct _put = self.channel._put for queue in _lookup(exchange, routing_key): _put(queue, message, **kwargs) |