diff --git a/alert/alert b/alert/alert index 7c27b9a..540e192 100755 --- a/alert/alert +++ b/alert/alert @@ -16,7 +16,7 @@ except IOError, e: fetcher = ctx.socket(zmq.SUB) fetcher.setsockopt(zmq.SUBSCRIBE, "") -fetcher.connect("ipc:///tmp/ccollectd-stats") +fetcher.connect("tcp://127.0.0.1:8998") class Bot(object): def __init__(self, hosts, port, nickname, realname, channels, admins, subsock): diff --git a/ccollectd/ccollectd b/ccollectd/ccollectd index 19edc83..c9efa72 100755 --- a/ccollectd/ccollectd +++ b/ccollectd/ccollectd @@ -6,7 +6,7 @@ from nacl.public import PublicKey, PrivateKey, Box ctx = zmq.Context() distributor = ctx.socket(zmq.PUB) -distributor.bind("ipc:///tmp/ccollectd-stats") +distributor.bind("tcp://127.0.0.1:8998") poller = zmq.Poller() diff --git a/ccollectd/listen b/ccollectd/listen index 6c19379..0b5c09f 100755 --- a/ccollectd/listen +++ b/ccollectd/listen @@ -1,12 +1,11 @@ #!/usr/bin/env python2 -import socket, yaml, random, zmq, msgpack, time, uuid, fnmatch -import cPickle as pickle +import zmq, msgpack ctx = zmq.Context() fetcher = ctx.socket(zmq.SUB) fetcher.setsockopt(zmq.SUBSCRIBE, "") -fetcher.connect("ipc:///tmp/ccollectd-stats") +fetcher.connect("tcp://127.0.0.1:8998") while True: message = msgpack.unpackb(fetcher.recv())