diff options
Diffstat (limited to 'heap/datastore/config.py')
-rw-r--r-- | heap/datastore/config.py | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/heap/datastore/config.py b/heap/datastore/config.py new file mode 100644 index 0000000..cd85f02 --- /dev/null +++ b/heap/datastore/config.py @@ -0,0 +1,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', +] + |