from kombu import Exchange, Queue
from settings import defaults

AMQP_URL = defaults['RACKHD_AMQP_URL']

# Task exchange queues
EXCHANGE_TASK           = Exchange('on.task', type='topic')
QUEUE_SEL_RESULT        = Queue('ipmi.command.sel.result',
                                EXCHANGE_TASK,
                                routing_key='ipmi.command.sel.result.*')
QUEUE_SDR_RESULT        = Queue('ipmi.command.sdr.result',
                                EXCHANGE_TASK,
                                routing_key='ipmi.command.sdr.result.*')
QUEUE_CHASSIS_RESULT    = Queue('ipmi.command.chassis.result',
                                EXCHANGE_TASK,
                                routing_key='ipmi.command.chassis.result.*')
                                
# Event exchange queues
EXCHANGE_EVENT          = Exchange('on.events', type='topic')
QUEUE_GRAPH_FINISH      = Queue('graph.finished',
                                EXCHANGE_EVENT,
                                routing_key='graph.finished.*')
QUEUE_SEL_ALERT      = Queue('poller.alert.sel',
                                EXCHANGE_EVENT,
                                routing_key='poller.alert.sel.#')
                                
def make_queue_obj(exchange, queue, routing_key, type='topic'):
    return Queue(queue, \
           Exchange(exchange, type=type), \
           routing_key=routing_key)