summaryrefslogtreecommitdiff
path: root/datastore/config.py
diff options
context:
space:
mode:
authorYves Fischer <yvesf-git@xapek.org>2013-01-11 20:01:09 +0100
committerYves Fischer <yvesf-git@xapek.org>2013-01-11 20:01:09 +0100
commit934d642b410d75dae1966c993fc61c371959876e (patch)
treeca9bcd22d98d88424be0d21d6387ddba779a9daa /datastore/config.py
parent69fbdff8e8ba69034111038ce01184ef5472728a (diff)
downloadebus-alt-934d642b410d75dae1966c993fc61c371959876e.tar.gz
ebus-alt-934d642b410d75dae1966c993fc61c371959876e.zip
datastore
Diffstat (limited to 'datastore/config.py')
-rw-r--r--datastore/config.py34
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',
+]
+