from store.channel import PrinterChannel, SimpleMemoryChannel
from store.processor import CountingProcessor

CHANNELS={
    'org.xapek.test1' : PrinterChannel("org.xapek.test1"),
    'org.xapek.test1.count' : SimpleMemoryChannel(),
    'arduino.a0' : PrinterChannel("a0"),
    'arduino.a0.dba' : PrinterChannel("a0.dba"),
    'arduino.a0.mv' : PrinterChannel("a0.mv"),
}

PROCESSORS={
    # key : queue-name subscribed with
    'org.xapek.test1' : [ CountingProcessor("org.xapek.test1.count"), ],
}


STOMP_HOST="10.2.2.26"
STOMP_PORT=61613
STOMP_LOGIN=""
STOMP_PASSCODE=""
STOMP_QUEUE_PUT="/queue/queue-put"
STOMP_QUEUE_GET="/queue/queue-get"
STOMP_QUEUE_SUBSCRIBE="/queue/queue-subscribe"


__all__ = [
    'CHANNELS',
    'STOMP_HOST',
    'STOMP_PORT',
    'STOMP_LOGIN',
    'STOMP_PASSCODE',
    'STOMP_QUEUE_PUT',
    'STOMP_QUEUE_GET',
    'STOMP_QUEUE_SUBSCRIBE',
]