diff --git a/kombu/entity.py b/kombu/entity.py index e0ea035e..87486070 100644 --- a/kombu/entity.py +++ b/kombu/entity.py @@ -730,3 +730,13 @@ class Queue(MaybeChannelBound): queue_arguments=q_arguments, binding_arguments=b_arguments, bindings=bindings) + + def as_dict(self, recurse=False): + res = super(Queue, self).as_dict(recurse) + if not recurse: + return res + bindings = res.get('bindings') + if bindings: + res['bindings'] = [b.as_dict(recurse=True) for b in bindings] + return res +