datastore foo

1 files changed, 7 insertions, 3 deletions

diff --git a/datastore/store/controller.py b/datastore/store/controller.py
index 0814488..0d694d1 100644
--- a/datastore/store/controller.py
+++ b/datastore/store/controller.py
@@ -1,4 +1,5 @@
 import traceback
+import time
 
 class SubscriptionManager:
     def __init__(self):
@@ -56,13 +57,16 @@ class StoreController:
 class MQStoreController(StoreController):
     def cb_put(self, frame):
         try:
+            if not frame.headers.has_key("timestamp"):
+                frame.headers['timestamp'] = str(time.time())
             assert len(frame.timestamp) > 0
             values = map(lambda kv: kv.split("="), frame.body.split("\n"))
+            values = filter(lambda x: len(x)==2, values) #filter non-pairs from empty lines
             for (name,data) in values:
-                assert self.channels.has_key(name)
+                if name not in self.channels.keys():
+                    print "No channel named {0}".format(name)
+                    continue
                 print name,"=",data
-
-            for (name,data) in values:
                 self.put(name, frame.timestamp, data)
         except Exception,e: traceback.print_exc()