From b9cc1b4832f4ebdc644a5aa2cf02e4ac40c56451 Mon Sep 17 00:00:00 2001 From: Ralph Bean Date: Tue, 28 Jan 2014 16:18:17 -0500 Subject: [PATCH] Disable epgm test --- txzmq/test/test_pubsub.py | 26 -------------------------- 1 file changed, 26 deletions(-) diff --git a/txzmq/test/test_pubsub.py b/txzmq/test/test_pubsub.py index 86a0238..f2fb12e 100644 --- a/txzmq/test/test_pubsub.py +++ b/txzmq/test/test_pubsub.py @@ -19,21 +19,6 @@ class ZmqTestSubConnection(ZmqSubConnection): self.messages.append([tag, message]) -def _detect_epgm(): - """ - Utility function to test for presence of epgm:// in zeromq. - """ - import zmq - - context = zmq.Context() - socket = zmq.Socket(context, zmq.constants.PUB) - - try: - socket.bind("epgm://127.0.0.1;239.192.1.1:5557") - - return True - except ZMQError: - return False class ZmqConnectionTestCase(unittest.TestCase): @@ -81,14 +66,6 @@ class ZmqConnectionTestCase(unittest.TestCase): return _wait(0.01).addCallback(publish) \ .addCallback(lambda _: _wait(0.01)).addCallback(check) - def test_send_recv_pgm(self): - r = ZmqTestSubConnection(self.factory, ZmqEndpoint( - ZmqEndpointType.bind, "epgm://127.0.0.1;239.192.1.1:5556")) - - s = ZmqPubConnection(self.factory, ZmqEndpoint( - ZmqEndpointType.connect, "epgm://127.0.0.1;239.192.1.1:5556")) - - r.subscribe('tag') def publish(ignore): s.publish('xyz', 'different-tag') @@ -130,6 +107,3 @@ class ZmqConnectionTestCase(unittest.TestCase): return _wait(0.1).addCallback(publish) \ .addCallback(lambda _: _wait(0.1)).addCallback(check) - - if not _detect_epgm(): - test_send_recv_pgm.skip = "epgm:// not available" -- 1.8.5.3