Corrections in Redis hook

synw · Jul 4, 2017 · 64dfc00 · 64dfc00
1 parent 9e7bf27
commit 64dfc00
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 6 deletions.
diff --git a/mqueue/hooks/redis/__init__.py b/mqueue/hooks/redis/__init__.py
@@ -10,5 +10,6 @@
 
 def save(event, conf):
     name = DOMAIN+"_event"+str(event_num)
-    data = serializer.Pack(event)
+    event.request = event.request.replace("\n", "//")
+    data = serializer.Pack(event)  
     R.set(name, data)
diff --git a/mqueue/hooks/redis/serializer.py b/mqueue/hooks/redis/serializer.py
@@ -1,5 +1,3 @@
-from hitsmon import conf
-
 def Pack(event):
     sep = "#!#"
     data = ["name:;"+event.name]
@@ -16,7 +14,7 @@ def Pack(event):
     if event.admin_url:
         data.append("admin_url:;"+event.admin_url)
     if event.notes:
-        data.append("notes:;"+event.notes)
+        data.append("notes:;"+str(event.notes))
     if event.request:
         data.append("request:;"+event.request)
     if event.bucket:

diff --git a/mqueue/models.py b/mqueue/models.py
@@ -106,8 +106,6 @@ def create(self, *args, **kwargs):
         channel = None
         if 'channel' in kwargs.keys():
             channel = kwargs['channel']
-        data = {}
-
         if stream is True:
             publish(message=name, event_class=event_class, channel=channel, data=data)
         # proceed hooks