Synnefo

                callback(self, result)

            else:

                log.debug("Message without body %s" % result)

        consume_promise = \

                self.client.basic_consume_multi(queues=queue,

        except (socket.error, puka.spec_exceptions.ConnectionForced):

            log.debug('Connection closed while receiving messages.')

            self.consume_promises = []

            self.connect()

            for queues, callback in self.consume_info.items():

                self.basic_consume(queues, callback)

        except (socket.error, puka.spec_exceptions.ConnectionForced):

            log.debug('Connection closed while receiving messages.')

            self.consume_promises = []

            self.connect()

            for queues in self.consume_queues:

                self.basic_consume(queues)

    """

    @wraps(func)

    def wrapper(client, message, *args, **kwargs):

        try:

            msg = json.loads(message['body'])

            db_time = vm.backendtime

            if event_time <= db_time:

                format_ = "%d/%m/%y %H:%M:%S:%f"

                          event_time.strftime(format_),

                          db_time.strftime(format_))

                client.basic_ack(message)

def dummy_proc(client, message):

    try:

        log.debug("Msg: %s", message['body'])

    except Exception as e:

        log.exception("Could not receive message")