diff options
author | Sergey Tikhonov <zimbler@gmail.com> | 2015-02-12 15:14:10 +0300 |
---|---|---|
committer | Sergey Tikhonov <zimbler@gmail.com> | 2015-02-12 15:14:10 +0300 |
commit | 9ff773aa68e56daa3ff1c03f29b623526d9109de (patch) | |
tree | 5116dc7a7d3bb0392c1dcb2285604d356fc45544 /kombu/entity.py | |
parent | 846179c19d7bc7f86bb99e3704e315e67f74c01d (diff) | |
download | kombu-9ff773aa68e56daa3ff1c03f29b623526d9109de.tar.gz |
fix json serializable error for active_queues
Diffstat (limited to 'kombu/entity.py')
-rw-r--r-- | kombu/entity.py | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/kombu/entity.py b/kombu/entity.py index e0ea035e..f7b294c2 100644 --- a/kombu/entity.py +++ b/kombu/entity.py @@ -7,7 +7,7 @@ Exchange and Queue declarations. """ from __future__ import absolute_import -from .abstract import MaybeChannelBound +from .abstract import MaybeChannelBound, Object from .exceptions import ContentDisallowed from .five import string_t from .serialization import prepare_accept_content @@ -299,7 +299,7 @@ class Exchange(MaybeChannelBound): return not self.auto_delete -class binding(object): +class binding(Object): """Represents a queue or exchange binding. :keyword exchange: Exchange to bind to. @@ -309,6 +309,13 @@ class binding(object): """ + attrs = ( + ('exchange', None), + ('routing_key', None), + ('arguments', None), + ('unbind_arguments', None) + ) + def __init__(self, exchange=None, routing_key='', arguments=None, unbind_arguments=None): self.exchange = exchange |