diff options
author | Yves Fischer <yvesf-git@xapek.org> | 2013-01-11 20:01:09 +0100 |
---|---|---|
committer | Yves Fischer <yvesf-git@xapek.org> | 2013-01-11 20:01:09 +0100 |
commit | 934d642b410d75dae1966c993fc61c371959876e (patch) | |
tree | ca9bcd22d98d88424be0d21d6387ddba779a9daa /datastore/config.py | |
parent | 69fbdff8e8ba69034111038ce01184ef5472728a (diff) | |
download | ebus-alt-934d642b410d75dae1966c993fc61c371959876e.tar.gz ebus-alt-934d642b410d75dae1966c993fc61c371959876e.zip |
datastore
Diffstat (limited to 'datastore/config.py')
-rw-r--r-- | datastore/config.py | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/datastore/config.py b/datastore/config.py new file mode 100644 index 0000000..9f615d2 --- /dev/null +++ b/datastore/config.py @@ -0,0 +1,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', +] + |