blob: 9f615d2c1208e3f47060839ee31d1160d5583e1a (
plain)
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
|
from store.channel import PrinterChannel, SimpleMemoryChannel
from store.processor import CountingProcessor
CHANNELS={
'org.xapek.test1' : PrinterChannel("org.xapek.test1"),
'org.xapek.test1.count' : SimpleMemoryChannel(),
}
PROCESSORS={
# key : queue-name subscribed with
'org.xapek.test1' : [ CountingProcessor("org.xapek.test1.count"), ],
}
STOMP_HOST="localhost"
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',
]
|
