summaryrefslogtreecommitdiff
path: root/kombu/entity.py
diff options
context:
space:
mode:
authorSergey Tikhonov <zimbler@gmail.com>2015-02-12 15:14:10 +0300
committerSergey Tikhonov <zimbler@gmail.com>2015-02-12 15:14:10 +0300
commit9ff773aa68e56daa3ff1c03f29b623526d9109de (patch)
tree5116dc7a7d3bb0392c1dcb2285604d356fc45544 /kombu/entity.py
parent846179c19d7bc7f86bb99e3704e315e67f74c01d (diff)
downloadkombu-9ff773aa68e56daa3ff1c03f29b623526d9109de.tar.gz
fix json serializable error for active_queues
Diffstat (limited to 'kombu/entity.py')
-rw-r--r--kombu/entity.py11
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