diff --git a/oslo_messaging/tests/functional/test_functional.py b/oslo_messaging/tests/functional/test_functional.py index 83116482b..ba9f2989c 100644 --- a/oslo_messaging/tests/functional/test_functional.py +++ b/oslo_messaging/tests/functional/test_functional.py @@ -258,7 +258,7 @@ class NotifyTestCase(utils.SkipIfNoTransportURL): def test_multiple_servers(self): if self.url.startswith("amqp:"): self.skipTest("QPID-6307") - if self.url.startswith("zmq:"): + if self.url.startswith("zmq"): self.skipTest("ZeroMQ-PUB-SUB") listener_a = self.useFixture( diff --git a/setup-test-env-zmq-proxy.sh b/setup-test-env-zmq-proxy.sh index e6c6db072..59e8efb85 100755 --- a/setup-test-env-zmq-proxy.sh +++ b/setup-test-env-zmq-proxy.sh @@ -6,13 +6,13 @@ set -e DATADIR=$(mktemp -d /tmp/OSLOMSG-ZEROMQ.XXXXX) trap "clean_exit $DATADIR" EXIT -export TRANSPORT_URL=zmq:// export ZMQ_MATCHMAKER=redis export ZMQ_REDIS_PORT=65123 export ZMQ_IPC_DIR=${DATADIR} export ZMQ_USE_PUB_SUB=false export ZMQ_USE_ROUTER_PROXY=true export ZMQ_USE_ACKS=false +export TRANSPORT_URL="zmq+${ZMQ_MATCHMAKER}://127.0.0.1:${ZMQ_REDIS_PORT}" export ZMQ_PROXY_HOST=127.0.0.1 @@ -20,13 +20,10 @@ cat > ${DATADIR}/zmq.conf < ${DATADIR}/zmq-proxy.log 2>&1 & +oslo-messaging-zmq-proxy --debug --url ${TRANSPORT_URL} --config-file ${DATADIR}/zmq.conf > ${DATADIR}/zmq-proxy.log 2>&1 & $* diff --git a/setup-test-env-zmq-pub-sub.sh b/setup-test-env-zmq-pub-sub.sh index ef99cf294..187076d40 100755 --- a/setup-test-env-zmq-pub-sub.sh +++ b/setup-test-env-zmq-pub-sub.sh @@ -6,13 +6,13 @@ set -e DATADIR=$(mktemp -d /tmp/OSLOMSG-ZEROMQ.XXXXX) trap "clean_exit $DATADIR" EXIT -export TRANSPORT_URL=zmq:// export ZMQ_MATCHMAKER=redis export ZMQ_REDIS_PORT=65123 export ZMQ_IPC_DIR=${DATADIR} export ZMQ_USE_PUB_SUB=true export ZMQ_USE_ROUTER_PROXY=true export ZMQ_USE_ACKS=false +export TRANSPORT_URL="zmq+${ZMQ_MATCHMAKER}://127.0.0.1:${ZMQ_REDIS_PORT}" export ZMQ_PROXY_HOST=127.0.0.1 @@ -20,13 +20,10 @@ cat > ${DATADIR}/zmq.conf < ${DATADIR}/zmq-proxy.log 2>&1 & +oslo-messaging-zmq-proxy --debug --url ${TRANSPORT_URL} --config-file ${DATADIR}/zmq.conf > ${DATADIR}/zmq-proxy.log 2>&1 & $* diff --git a/setup-test-env-zmq.sh b/setup-test-env-zmq.sh index 87808723d..e6b219d5f 100755 --- a/setup-test-env-zmq.sh +++ b/setup-test-env-zmq.sh @@ -6,27 +6,25 @@ set -e DATADIR=$(mktemp -d /tmp/OSLOMSG-ZEROMQ.XXXXX) trap "clean_exit $DATADIR" EXIT -export TRANSPORT_URL=zmq:// export ZMQ_MATCHMAKER=redis export ZMQ_REDIS_PORT=65123 export ZMQ_IPC_DIR=${DATADIR} export ZMQ_USE_PUB_SUB=false export ZMQ_USE_ROUTER_PROXY=false +export ZMQ_USE_ACKS=false +export TRANSPORT_URL="zmq+${ZMQ_MATCHMAKER}://127.0.0.1:${ZMQ_REDIS_PORT}" cat > ${DATADIR}/zmq.conf < ${DATADIR}/zmq-proxy.log 2>&1 & +oslo-messaging-zmq-proxy --debug --url ${TRANSPORT_URL} --config-file ${DATADIR}/zmq.conf > ${DATADIR}/zmq-proxy.log 2>&1 & $*