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/exchange.py | |
| parent | d2ebf4822077f0dc9d38636dd3bbcd2954fbaf23 (diff) | |
| download | kombu-f16ab3a0910b8748040e77d4e226f3f9c5780d9c.tar.gz | |
Adds "#" + "*" to regex escape whitelist
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 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): |