diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-06-11 21:41:18 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-06-11 21:41:18 +0000 |
| commit | b13651d9142c7e928568a99b94bfad5ca2c99d31 (patch) | |
| tree | dffb8267fc770ec4c70cf61a70d3846a91f557af | |
| parent | 36d967b6380ea7cc066e362c5525de767356000e (diff) | |
| parent | 32e2a25977f44b87c382d3a879b9ce7aabdd0bf9 (diff) | |
| download | oslo-b13651d9142c7e928568a99b94bfad5ca2c99d31.tar.gz oslo-b13651d9142c7e928568a99b94bfad5ca2c99d31.tar.xz oslo-b13651d9142c7e928568a99b94bfad5ca2c99d31.zip | |
Merge "zmq: remove someone unused code from ZmqClient"
| -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 0bb5741..0b10997 100644 --- a/openstack/common/rpc/impl_zmq.py +++ b/openstack/common/rpc/impl_zmq.py @@ -209,12 +209,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: |