1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
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',
]
|
