We're not using prefix matching on AMQP, so fakerabbit shouldn't be doing it!

This commit is contained in:
Justin Santa Barbara 2011-02-22 15:05:48 -08:00
parent 3180d5dcf9
commit f4289df0e5

View File

@ -48,7 +48,6 @@ class Exchange(object):
nm = self.name
LOG.debug(_('(%(nm)s) publish (key: %(routing_key)s)'
' %(message)s') % locals())
routing_key = routing_key.split('.')[0]
if routing_key in self._routes:
for f in self._routes[routing_key]:
LOG.debug(_('Publishing to route %s'), f)