diff options
| author | Mark McLoughlin <markmc@redhat.com> | 2013-06-06 10:50:02 +0100 |
|---|---|---|
| committer | Mark McLoughlin <markmc@redhat.com> | 2013-06-06 10:50:02 +0100 |
| commit | 32e2a25977f44b87c382d3a879b9ce7aabdd0bf9 (patch) | |
| tree | 64a957800ccdebc0323bcb168bb7cea91248abb3 | |
| parent | 3f315db8dab8a859e7204e7ac184ea9796273a74 (diff) | |
| download | oslo-32e2a25977f44b87c382d3a879b9ce7aabdd0bf9.tar.gz oslo-32e2a25977f44b87c382d3a879b9ce7aabdd0bf9.tar.xz oslo-32e2a25977f44b87c382d3a879b9ce7aabdd0bf9.zip | |
zmq: remove someone unused code from ZmqClient
The socket_type and bind constructor args are never used.
We always supply a value for the envelope argument.
Change-Id: Ide2e11170a3415ef347f85bfcce759cdd55d1225
| -rw-r--r-- | openstack/common/rpc/impl_zmq.py | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/openstack/common/rpc/impl_zmq.py b/openstack/common/rpc/impl_zmq.py index 07b7b41..5de6a42 100644 --- a/openstack/common/rpc/impl_zmq.py +++ b/openstack/common/rpc/impl_zmq.py @@ -212,12 +212,10 @@ class ZmqSocket(object): class ZmqClient(object): """Client for ZMQ sockets.""" - def __init__(self, addr, socket_type=None, bind=False): - if socket_type is None: - socket_type = zmq.PUSH - self.outq = ZmqSocket(addr, socket_type, bind=bind) + def __init__(self, addr): + self.outq = ZmqSocket(addr, zmq.PUSH, bind=False) - def cast(self, msg_id, topic, data, envelope=False): + def cast(self, msg_id, topic, data, envelope): msg_id = msg_id or 0 if not envelope: |