Synnefo

            return func(self, *args, **kwargs)

        except (socket_error, spec_exceptions.ConnectionForced) as e:

            logger.error('Connection Closed while in %s: %s', func.__name__, e)

            self.connect()

    return wrapper

        logger.info('Creating channel')

        if self.unacked:

            self._resend_unacked_messages()

            for exchange, type in exchanges:

                self.exchange_declare(exchange, type)

    def exchange_declare(self, exchange, type='direct'):

        """Declare an exchange

        @type exchange_name: string

        """

        if promise is not None:

        else:

    @reconnect_decorator

    def basic_get(self, queue):

    def close(self):

        """Check that messages have been send and close the connection."""

        try:

            if self.confirms:

                self.get_confirms()

    def wait(self):

        log.info("Waiting for messages..")

        while True:

            try:

                # Close the Django DB connection before processing

                # the dispatcher to recover from broken connections

                # gracefully.

                close_connection()

            except SystemExit:

                break

            except Exception as e: