Merge "[zmq] Fix slow down"
This commit is contained in:
commit
11d7c44a36
oslo_messaging
@ -12,7 +12,6 @@
|
|||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import contextlib
|
|
||||||
import logging
|
import logging
|
||||||
import sys
|
import sys
|
||||||
import time
|
import time
|
||||||
@ -33,8 +32,8 @@ def main():
|
|||||||
CONF(sys.argv[1:], project='oslo')
|
CONF(sys.argv[1:], project='oslo')
|
||||||
logging.basicConfig(level=logging.DEBUG)
|
logging.basicConfig(level=logging.DEBUG)
|
||||||
|
|
||||||
with contextlib.closing(zmq_broker.ZmqBroker(CONF)) as reactor:
|
reactor = zmq_broker.ZmqBroker(CONF)
|
||||||
reactor.start()
|
reactor.start()
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
time.sleep(1)
|
time.sleep(1)
|
||||||
|
@ -70,7 +70,7 @@ zmq_opts = [
|
|||||||
help='Expiration timeout in seconds of a name service record '
|
help='Expiration timeout in seconds of a name service record '
|
||||||
'about existing target ( < 0 means no timeout).'),
|
'about existing target ( < 0 means no timeout).'),
|
||||||
|
|
||||||
cfg.BoolOpt('use_pub_sub', default=False,
|
cfg.BoolOpt('use_pub_sub', default=True,
|
||||||
help='Use PUB/SUB pattern for fanout methods. '
|
help='Use PUB/SUB pattern for fanout methods. '
|
||||||
'PUB/SUB always uses proxy.'),
|
'PUB/SUB always uses proxy.'),
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user