diff --git a/collect.py b/collect.py index bf184f6..a4da229 100644 --- a/collect.py +++ b/collect.py @@ -2,7 +2,7 @@ import zmq, msgpack, json, os, time context = zmq.Context() socket = context.socket(zmq.PULL) -socket.connect("ipc:///tmp/pbscrape-results") +socket.bind("ipc:///tmp/pbscrape-results") try: os.makedirs("pastes") diff --git a/retrieve.py b/retrieve.py index 5fdeaef..92438ae 100644 --- a/retrieve.py +++ b/retrieve.py @@ -4,7 +4,7 @@ context = zmq.Context() receiver = context.socket(zmq.PULL) receiver.connect("ipc:///tmp/pbscrape-tasks") sender = context.socket(zmq.PUSH) -sender.bind("ipc:///tmp/pbscrape-results") +sender.connect("ipc:///tmp/pbscrape-results") while True: item = msgpack.unpackb(receiver.recv())