def __init__(self, exchange, queue, routing_key=None, buffer_maxsize=None, *args, **kwargs):
    super().__init__()
    self._args = args
    self._kwargs = kwargs
    self._exchange = exchange
    self._queue = queue
    self._routing_key = (routing_key or queue)
    self._buffer = (Queue(buffer_maxsize) if (buffer_maxsize is not None) else None)
    self._declared = False
def __init__(self, exchange, queue, routing_key=None, buffer_maxsize=None, *args, **kwargs):
    super().__init__()
    self._args = args
    self._kwargs = kwargs
    self._exchange = exchange
    self._queue = queue
    self._routing_key = (routing_key or queue)
    self._buffer = (Queue(buffer_maxsize) if (buffer_maxsize is not None) else None)
    self._declared = False