Index: trunk/zoo-project/zoo-services/utils/open-api/server/publish.py
===================================================================
--- trunk/zoo-project/zoo-services/utils/open-api/server/publish.py	(revision 967)
+++ trunk/zoo-project/zoo-services/utils/open-api/server/publish.py	(revision 968)
@@ -14,9 +14,14 @@
 
 from urllib import parse
+
 try:
-	params=parse.parse_qs(os.environ["QUERY_STRING"])
-	r = redis.Redis(host='localhost', port=6379, db=0)
-	print(params)
-	r.publish(params["jobid"][0],data)
+    params=parse.parse_qs(os.environ["QUERY_STRING"])
+    r=None
+    if "ZOO_REDIS_HOST" in os.environ:
+        r = redis.Redis(host=os.environ["ZOO_REDIS_HOST"], port=6379, db=0)
+    else:
+        r = redis.Redis(host='redis', port=6379, db=0)
+    print(params)
+    r.publish(params["jobid"][0],data)
 except Exception as e:
 	print(e)
Index: trunk/zoo-project/zoo-services/utils/open-api/server/subscriber.py
===================================================================
--- trunk/zoo-project/zoo-services/utils/open-api/server/subscriber.py	(revision 967)
+++ trunk/zoo-project/zoo-services/utils/open-api/server/subscriber.py	(revision 968)
@@ -11,7 +11,13 @@
 import redis
 import json
+import os
 
 mThreads=[]
-r = redis.Redis(host='localhost', port=6379, db=0)
+r=None
+
+if "ZOO_REDIS_HOST" in os.environ:
+    r = redis.Redis(host=os.environ["ZOO_REDIS_HOST"], port=6379, db=0)
+else:
+    r = redis.Redis(host='redis', port=6379, db=0)
 
 def send(t):
@@ -59,4 +65,4 @@
 
 t0.join()
-for i in range(len(mThreads)):
-    mThreads[i].join()
+#for i in range(len(mThreads)):
+#    mThreads[i].join()