# Path: studio/storage/storage_setup.py
# def get_storage_verbose_level():
#     global _storage_verbose_level
#     return _storage_verbose_level
# 
# Path: studio/util/logs.py
# DEBUG = logging.DEBUG
# INFO = logging.INFO
# ERROR = logging.ERROR
# def get_logger(name):
# def debug(line):
# def error(line):
# def info(line):


import time
import threading
import pika
from studio.storage.storage_setup import get_storage_verbose_level
from studio.util import logs
            self._channel.queue_declare(queue_name,
                                        durable=self._is_persistent,
                                        callback=self._on_queue_declareok)

    def _on_queue_declareok(self, method_frame):
        """
        Queue.Declare RPC completion callback.
        In this method the queue and exchange are bound together
        with the routing key by issuing the Queue.Bind
        RPC command.

        The completion callback is the _on_bindok method.

        :param pika.frame.Method method_frame: The Queue.DeclareOk frame

        """
        _ = method_frame
        self._logger.info('binding %s to queue %s with %s',
                          self._exchange, self._queue, self._routing_key)
        with self._rmq_lock:
            self._channel.queue_bind(self._queue,
                                     self._exchange,
                                     routing_key=self._routing_key,
                                     callback=self._on_bindok)

    def _on_bindok(self, unused_frame):
        """This method is invoked by pika when it receives the Queue.BindOk
        response from RabbitMQ. Since we know we're now setup and bound, it's
        time to start publishing."""
        self._logger.info('bound %s to queue %s with %s',

# Path: studio/storage/storage_setup.py
# def get_storage_verbose_level():
#     global _storage_verbose_level
#     return _storage_verbose_level
# 
# Path: studio/util/logs.py
# DEBUG = logging.DEBUG
# INFO = logging.INFO
# ERROR = logging.ERROR
# def get_logger(name):
# def debug(line):
# def error(line):
# def info(line):


# Path: studio/queues/rabbit_queue.py
import time
import threading
import pika
from studio.storage.storage_setup import get_storage_verbose_level
from studio.util import logs

            self._channel.queue_declare(queue_name,
                                        durable=self._is_persistent,
                                        callback=self._on_queue_declareok)

    def _on_queue_declareok(self, method_frame):
        """
        Queue.Declare RPC completion callback.
        In this method the queue and exchange are bound together
        with the routing key by issuing the Queue.Bind
        RPC command.

        The completion callback is the _on_bindok method.

        :param pika.frame.Method method_frame: The Queue.DeclareOk frame

        """
        _ = method_frame
        self._logger.info('binding %s to queue %s with %s',
                          self._exchange, self._queue, self._routing_key)
        with self._rmq_lock:
            self._channel.queue_bind(self._queue,
                                     self._exchange,
                                     routing_key=self._routing_key,
                                     callback=self._on_bindok)

    def _on_bindok(self, unused_frame):
        """This method is invoked by pika when it receives the Queue.BindOk
        response from RabbitMQ. Since we know we're now setup and bound, it's
        time to start publishing."""
        self._logger.info('bound %s to queue %s with %s',

                          self._exchange, self._queue, self._routing_key)