diff options
author | Ask Solem <ask@celeryproject.org> | 2013-02-07 17:04:24 +0000 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2013-02-07 17:04:24 +0000 |
commit | f16ab3a0910b8748040e77d4e226f3f9c5780d9c (patch) | |
tree | b095d05375fbca73fe9b0fdd8a71e14607b47f66 /kombu/transport/virtual | |
parent | d2ebf4822077f0dc9d38636dd3bbcd2954fbaf23 (diff) | |
download | kombu-f16ab3a0910b8748040e77d4e226f3f9c5780d9c.tar.gz |
Adds "#" + "*" to regex escape whitelist
Diffstat (limited to 'kombu/transport/virtual')
-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 69d79261..c090a546 100644 --- a/kombu/transport/virtual/exchange.py +++ b/kombu/transport/virtual/exchange.py @@ -93,7 +93,7 @@ class TopicExchange(ExchangeType): """Get the corresponding regex for any routing key.""" return '^%s$' % ('\.'.join( self.wildcards.get(word, word) - for word in escape_regex(rkey, '.').split('.') + for word in escape_regex(rkey, '.#*').split('.') )) def _match(self, pattern, string): |