From e4d73f1a9a6823f0acad8852da51bca51474855b Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Wed, 9 May 2018 17:51:11 +0200 Subject: [PATCH] Test all examples with all possible transports --- examples/1-1/CMakeLists.txt | 10 ++++++++-- examples/1-1/test-ex-1-1.sh.in | 10 ++++++++++ examples/1-n-1/CMakeLists.txt | 10 ++++++++-- examples/1-n-1/test-ex-1-n-1.sh.in | 10 ++++++++++ examples/copypush/CMakeLists.txt | 10 ++++++++-- examples/copypush/test-ex-copypush.sh.in | 9 +++++++++ examples/multipart/CMakeLists.txt | 10 ++++++++-- examples/multipart/test-ex-multipart.sh.in | 8 ++++++++ examples/multiple-channels/CMakeLists.txt | 7 +++++-- .../multiple-channels/test-ex-multiple-channels.sh.in | 9 +++++++++ examples/region/CMakeLists.txt | 10 ++++++++-- examples/region/test-ex-region.sh.in | 10 ++++++++-- examples/req-rep/CMakeLists.txt | 10 ++++++++-- examples/req-rep/test-ex-req-rep.sh.in | 8 ++++++++ 14 files changed, 115 insertions(+), 16 deletions(-) diff --git a/examples/1-1/CMakeLists.txt b/examples/1-1/CMakeLists.txt index d14b2dbb..5a492a1e 100644 --- a/examples/1-1/CMakeLists.txt +++ b/examples/1-1/CMakeLists.txt @@ -31,8 +31,14 @@ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/fairmq-start-ex-1-1.sh.in ${CMAKE_CUR configure_file(${CMAKE_CURRENT_SOURCE_DIR}/test-ex-1-1.sh.in ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-1.sh) -add_test(NAME Example-1-1 COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-1.sh) -set_tests_properties(Example-1-1 PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") +add_test(NAME Example-1-1-zeromq COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-1.sh zeromq) +set_tests_properties(Example-1-1-zeromq PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") + +add_test(NAME Example-1-1-nanomsg COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-1.sh nanomsg) +set_tests_properties(Example-1-1-nanomsg PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") + +add_test(NAME Example-1-1-shmem COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-1.sh shmem) +set_tests_properties(Example-1-1-shmem PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") # install diff --git a/examples/1-1/test-ex-1-1.sh.in b/examples/1-1/test-ex-1-1.sh.in index ae654d2e..83b08048 100755 --- a/examples/1-1/test-ex-1-1.sh.in +++ b/examples/1-1/test-ex-1-1.sh.in @@ -1,10 +1,19 @@ #!/bin/bash +export FAIRMQ_PATH=@FAIRMQ_BIN_DIR@ + +transport="zeromq" + +if [[ $1 =~ ^[a-z]+$ ]]; then + transport=$1 +fi + # setup a trap to kill everything if the test fails/timeouts trap 'kill -TERM $SAMPLER_PID; kill -TERM $SINK_PID; wait $SAMPLER_PID; wait $SINK_PID;' TERM SAMPLER="fairmq-ex-1-1-sampler" SAMPLER+=" --id sampler1" +SAMPLER+=" --transport $transport" SAMPLER+=" --verbosity veryhigh" SAMPLER+=" --control static --color false" SAMPLER+=" --max-iterations 1" @@ -14,6 +23,7 @@ SAMPLER_PID=$! SINK="fairmq-ex-1-1-sink" SINK+=" --id sink1" +SINK+=" --transport $transport" SINK+=" --verbosity veryhigh" SINK+=" --control static --color false" SINK+=" --max-iterations 1" diff --git a/examples/1-n-1/CMakeLists.txt b/examples/1-n-1/CMakeLists.txt index 670bda4b..b9710374 100644 --- a/examples/1-n-1/CMakeLists.txt +++ b/examples/1-n-1/CMakeLists.txt @@ -39,8 +39,14 @@ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/ex-1-n-1.json ${CMAKE_CURRENT_BINARY_ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/test-ex-1-n-1.sh.in ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-n-1.sh) -add_test(NAME Example-1-n-1 COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-n-1.sh) -set_tests_properties(Example-1-n-1 PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") +add_test(NAME Example-1-n-1-zeromq COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-n-1.sh zeromq) +set_tests_properties(Example-1-n-1-zeromq PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") + +add_test(NAME Example-1-n-1-nanomsg COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-n-1.sh nanomsg) +set_tests_properties(Example-1-n-1-nanomsg PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") + +add_test(NAME Example-1-n-1-shmem COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-1-n-1.sh shmem) +set_tests_properties(Example-1-n-1-shmem PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received: ") # install diff --git a/examples/1-n-1/test-ex-1-n-1.sh.in b/examples/1-n-1/test-ex-1-n-1.sh.in index c963df7a..bce62771 100755 --- a/examples/1-n-1/test-ex-1-n-1.sh.in +++ b/examples/1-n-1/test-ex-1-n-1.sh.in @@ -2,6 +2,12 @@ export FAIRMQ_PATH=@FAIRMQ_BIN_DIR@ +transport="zeromq" + +if [[ $1 =~ ^[a-z]+$ ]]; then + transport=$1 +fi + ex2config="@CMAKE_CURRENT_BINARY_DIR@/ex-1-n-1.json" # setup a trap to kill everything if the test fails/timeouts @@ -9,6 +15,7 @@ trap 'kill -TERM $SAMPLER_PID; kill -TERM $SINK_PID; kill -TERM $PROCESSOR1_PID; SAMPLER="fairmq-ex-1-n-1-sampler" SAMPLER+=" --id sampler1" +SAMPLER+=" --transport $transport" SAMPLER+=" --verbosity veryhigh" SAMPLER+=" --control static --color false" SAMPLER+=" --max-iterations 2" @@ -18,6 +25,7 @@ SAMPLER_PID=$! PROCESSOR1="fairmq-ex-1-n-1-processor" PROCESSOR1+=" --id processor1" +PROCESSOR1+=" --transport $transport" PROCESSOR1+=" --verbosity veryhigh" PROCESSOR1+=" --control static --color false" PROCESSOR1+=" --mq-config $ex2config" @@ -27,6 +35,7 @@ PROCESSOR1_PID=$! PROCESSOR2="fairmq-ex-1-n-1-processor" PROCESSOR2+=" --id processor2" +PROCESSOR2+=" --transport $transport" PROCESSOR2+=" --verbosity veryhigh" PROCESSOR2+=" --control static --color false" PROCESSOR2+=" --mq-config $ex2config" @@ -36,6 +45,7 @@ PROCESSOR2_PID=$! SINK="fairmq-ex-1-n-1-sink" SINK+=" --id sink1" +SINK+=" --transport $transport" SINK+=" --verbosity veryhigh" SINK+=" --control static --color false" SINK+=" --max-iterations 2" diff --git a/examples/copypush/CMakeLists.txt b/examples/copypush/CMakeLists.txt index 7ceb82c0..50fe4fa4 100644 --- a/examples/copypush/CMakeLists.txt +++ b/examples/copypush/CMakeLists.txt @@ -32,8 +32,14 @@ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/fairmq-start-ex-copypush.sh.in ${CMAK configure_file(${CMAKE_CURRENT_SOURCE_DIR}/test-ex-copypush.sh.in ${CMAKE_CURRENT_BINARY_DIR}/test-ex-copypush.sh) -add_test(NAME Example-CopyPush COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-copypush.sh) -set_tests_properties(Example-CopyPush PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message: ") +add_test(NAME Example-CopyPush-zeromq COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-copypush.sh zeromq) +set_tests_properties(Example-CopyPush-zeromq PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message: ") + +add_test(NAME Example-CopyPush-nanomsg COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-copypush.sh nanomsg) +set_tests_properties(Example-CopyPush-nanomsg PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message: ") + +add_test(NAME Example-CopyPush-shmem COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-copypush.sh shmem) +set_tests_properties(Example-CopyPush-shmem PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message: ") # install diff --git a/examples/copypush/test-ex-copypush.sh.in b/examples/copypush/test-ex-copypush.sh.in index e002648d..cc0d88e7 100755 --- a/examples/copypush/test-ex-copypush.sh.in +++ b/examples/copypush/test-ex-copypush.sh.in @@ -2,11 +2,18 @@ export FAIRMQ_PATH=@FAIRMQ_BIN_DIR@ +transport="zeromq" + +if [[ $1 =~ ^[a-z]+$ ]]; then + transport=$1 +fi + # setup a trap to kill everything if the test fails/timeouts trap 'kill -TERM $SAMPLER_PID; kill -TERM $SINK1_PID; kill -TERM $SINK2_PID; wait $SAMPLER_PID; wait $SINK1_PID; wait $SINK2_PID;' TERM SAMPLER="fairmq-ex-copypush-sampler" SAMPLER+=" --id sampler1" +SAMPLER+=" --transport $transport" SAMPLER+=" --verbosity veryhigh" SAMPLER+=" --control static --color false" SAMPLER+=" --max-iterations 1" @@ -16,6 +23,7 @@ SAMPLER_PID=$! SINK1="fairmq-ex-copypush-sink" SINK1+=" --id sink1" +SINK1+=" --transport $transport" SINK1+=" --verbosity veryhigh" SINK1+=" --control static --color false" SINK1+=" --max-iterations 1" @@ -25,6 +33,7 @@ SINK1_PID=$! SINK2="fairmq-ex-copypush-sink" SINK2+=" --id sink2" +SINK2+=" --transport $transport" SINK2+=" --verbosity veryhigh" SINK2+=" --control static --color false" SINK2+=" --max-iterations 1" diff --git a/examples/multipart/CMakeLists.txt b/examples/multipart/CMakeLists.txt index 2e545083..0dc56e92 100644 --- a/examples/multipart/CMakeLists.txt +++ b/examples/multipart/CMakeLists.txt @@ -31,8 +31,14 @@ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/fairmq-start-ex-multipart.sh.in ${CMA configure_file(${CMAKE_CURRENT_SOURCE_DIR}/test-ex-multipart.sh.in ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multipart.sh) -add_test(NAME Example-Multipart COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multipart.sh) -set_tests_properties(Example-Multipart PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message with 2 parts") +add_test(NAME Example-Multipart-zeromq COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multipart.sh zeromq) +set_tests_properties(Example-Multipart-zeromq PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message with 2 parts") + +add_test(NAME Example-Multipart-nanomsg COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multipart.sh nanomsg) +set_tests_properties(Example-Multipart-nanomsg PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message with 2 parts") + +add_test(NAME Example-Multipart-shmem COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multipart.sh shmem) +set_tests_properties(Example-Multipart-shmem PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received message with 2 parts") # install diff --git a/examples/multipart/test-ex-multipart.sh.in b/examples/multipart/test-ex-multipart.sh.in index db3bdf53..08c104ff 100755 --- a/examples/multipart/test-ex-multipart.sh.in +++ b/examples/multipart/test-ex-multipart.sh.in @@ -2,11 +2,18 @@ export FAIRMQ_PATH=@FAIRMQ_BIN_DIR@ +transport="zeromq" + +if [[ $1 =~ ^[a-z]+$ ]]; then + transport=$1 +fi + # setup a trap to kill everything if the test fails/timeouts trap 'kill -TERM $SAMPLER_PID; kill -TERM $SINK_PID; wait $SAMPLER_PID; wait $SINK_PID;' TERM SAMPLER="fairmq-ex-multipart-sampler" SAMPLER+=" --id sampler1" +SAMPLER+=" --transport $transport" SAMPLER+=" --verbosity veryhigh" SAMPLER+=" --max-iterations 1" SAMPLER+=" --control static --color false" @@ -16,6 +23,7 @@ SAMPLER_PID=$! SINK="fairmq-ex-multipart-sink" SINK+=" --id sink1" +SINK+=" --transport $transport" SINK+=" --verbosity veryhigh" SINK+=" --control static --color false" SINK+=" --channel-config name=data,type=pull,method=bind,rateLogging=0,address=tcp://127.0.0.1:5555" diff --git a/examples/multiple-channels/CMakeLists.txt b/examples/multiple-channels/CMakeLists.txt index bdb75cc2..09fe883e 100644 --- a/examples/multiple-channels/CMakeLists.txt +++ b/examples/multiple-channels/CMakeLists.txt @@ -36,8 +36,11 @@ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/fairmq-start-ex-multiple-channels.sh. configure_file(${CMAKE_CURRENT_SOURCE_DIR}/test-ex-multiple-channels.sh.in ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multiple-channels.sh) -add_test(NAME Example-Multiple-Channels COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multiple-channels.sh) -set_tests_properties(Example-Multiple-Channels PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received messages from both sources.") +add_test(NAME Example-Multiple-Channels-zeromq COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multiple-channels.sh zeromq) +set_tests_properties(Example-Multiple-Channels-zeromq PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received messages from both sources.") + +add_test(NAME Example-Multiple-Channels-nanomsg COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-multiple-channels.sh nanomsg) +set_tests_properties(Example-Multiple-Channels-nanomsg PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received messages from both sources.") # install diff --git a/examples/multiple-channels/test-ex-multiple-channels.sh.in b/examples/multiple-channels/test-ex-multiple-channels.sh.in index 549872a8..dcaa2403 100755 --- a/examples/multiple-channels/test-ex-multiple-channels.sh.in +++ b/examples/multiple-channels/test-ex-multiple-channels.sh.in @@ -2,12 +2,19 @@ export FAIRMQ_PATH=@FAIRMQ_BIN_DIR@ +transport="zeromq" + +if [[ $1 =~ ^[a-z]+$ ]]; then + transport=$1 +fi + # setup a trap to kill everything if the test fails/timeouts trap 'kill -TERM $SAMPLER_PID; kill -TERM $SINK_PID; kill -TERM $BROADCASTER_PID; wait $SAMPLER_PID; wait $SINK_PID; wait $BROADCASTER_PID;' TERM SINK="fairmq-ex-multiple-channels-sink" SINK+=" --id sink1" +SINK+=" --transport $transport" SINK+=" --verbosity veryhigh" SINK+=" --max-iterations 1" SINK+=" --control static --color false" @@ -20,6 +27,7 @@ sleep 1 SAMPLER="fairmq-ex-multiple-channels-sampler" SAMPLER+=" --id sampler1" +SAMPLER+=" --transport $transport" SAMPLER+=" --verbosity veryhigh" SAMPLER+=" --max-iterations 1" SAMPLER+=" --control static --color false" @@ -30,6 +38,7 @@ SAMPLER_PID=$! BROADCASTER="fairmq-ex-multiple-channels-broadcaster" BROADCASTER+=" --id broadcaster1" +BROADCASTER+=" --transport $transport" BROADCASTER+=" --verbosity veryhigh" BROADCASTER+=" --control static --color false" BROADCASTER+=" --channel-config name=broadcast,type=pub,method=bind,rateLogging=0,address=tcp://*:5005" diff --git a/examples/region/CMakeLists.txt b/examples/region/CMakeLists.txt index ccc128de..374b49e9 100644 --- a/examples/region/CMakeLists.txt +++ b/examples/region/CMakeLists.txt @@ -32,8 +32,14 @@ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/fairmq-start-ex-region.sh.in ${CMAKE_ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/test-ex-region.sh.in ${CMAKE_CURRENT_BINARY_DIR}/test-ex-region.sh) -add_test(NAME Example-Region COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-region.sh) -set_tests_properties(Example-Region PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received ack") +add_test(NAME Example-Region-zeromq COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-region.sh zeromq) +set_tests_properties(Example-Region-zeromq PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received ack") + +add_test(NAME Example-Region-nanomsg COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-region.sh nanomsg) +set_tests_properties(Example-Region-nanomsg PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received ack") + +add_test(NAME Example-Region-shmem COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-region.sh shmem) +set_tests_properties(Example-Region-shmem PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received ack") # install diff --git a/examples/region/test-ex-region.sh.in b/examples/region/test-ex-region.sh.in index 595688b2..e1139154 100755 --- a/examples/region/test-ex-region.sh.in +++ b/examples/region/test-ex-region.sh.in @@ -2,6 +2,12 @@ export FAIRMQ_PATH=@FAIRMQ_BIN_DIR@ +transport="zeromq" + +if [[ $1 =~ ^[a-z]+$ ]]; then + transport=$1 +fi + msgSize="1000000" SESSION="$(@CMAKE_BINARY_DIR@/fairmq/fairmq-uuid-gen -h)" @@ -10,23 +16,23 @@ trap 'kill -TERM $SAMPLER_PID; kill -TERM $SINK_PID; wait $SAMPLER_PID; wait $SI SAMPLER="fairmq-ex-region-sampler" SAMPLER+=" --id sampler1" +SAMPLER+=" --transport $transport" SAMPLER+=" --severity debug" SAMPLER+=" --session $SESSION" SAMPLER+=" --control static --color false" SAMPLER+=" --max-iterations 1" SAMPLER+=" --msg-size $msgSize" -SAMPLER+=" --transport shmem" SAMPLER+=" --channel-config name=data,type=push,method=bind,address=tcp://127.0.0.1:7777" @CMAKE_CURRENT_BINARY_DIR@/$SAMPLER & SAMPLER_PID=$! SINK="fairmq-ex-region-sink" SINK+=" --id sink1" +SINK+=" --transport $transport" SINK+=" --session $SESSION" SINK+=" --verbosity veryhigh" SINK+=" --control static --color false" SINK+=" --max-iterations 1" -SINK+=" --transport shmem" SINK+=" --channel-config name=data,type=pull,method=connect,address=tcp://127.0.0.1:7777" @CMAKE_CURRENT_BINARY_DIR@/$SINK & SINK_PID=$! diff --git a/examples/req-rep/CMakeLists.txt b/examples/req-rep/CMakeLists.txt index 0c007fe2..ad202bd7 100644 --- a/examples/req-rep/CMakeLists.txt +++ b/examples/req-rep/CMakeLists.txt @@ -32,8 +32,14 @@ configure_file(${CMAKE_CURRENT_SOURCE_DIR}/fairmq-start-ex-req-rep.sh.in ${CMAKE configure_file(${CMAKE_CURRENT_SOURCE_DIR}/test-ex-req-rep.sh.in ${CMAKE_CURRENT_BINARY_DIR}/test-ex-req-rep.sh) -add_test(NAME Example-ReqRep COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-req-rep.sh) -set_tests_properties(Example-ReqRep PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received reply from server: ") +add_test(NAME Example-ReqRep-zeromq COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-req-rep.sh zeromq) +set_tests_properties(Example-ReqRep-zeromq PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received reply from server: ") + +add_test(NAME Example-ReqRep-nanomsg COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-req-rep.sh nanomsg) +set_tests_properties(Example-ReqRep-nanomsg PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received reply from server: ") + +add_test(NAME Example-ReqRep-shmem COMMAND ${CMAKE_CURRENT_BINARY_DIR}/test-ex-req-rep.sh shmem) +set_tests_properties(Example-ReqRep-shmem PROPERTIES TIMEOUT "30" RUN_SERIAL true PASS_REGULAR_EXPRESSION "Received reply from server: ") # install diff --git a/examples/req-rep/test-ex-req-rep.sh.in b/examples/req-rep/test-ex-req-rep.sh.in index a6953103..c4f75932 100755 --- a/examples/req-rep/test-ex-req-rep.sh.in +++ b/examples/req-rep/test-ex-req-rep.sh.in @@ -2,11 +2,18 @@ export FAIRMQ_PATH=@FAIRMQ_BIN_DIR@ +transport="zeromq" + +if [[ $1 =~ ^[a-z]+$ ]]; then + transport=$1 +fi + # setup a trap to kill everything if the test fails/timeouts trap 'kill -TERM $CLIENT_PID; kill -TERM $SERVER_PID; wait $CLIENT_PID; wait $SERVER_PID;' TERM CLIENT="fairmq-ex-req-rep-client" CLIENT+=" --id client" +CLIENT+=" --transport $transport" CLIENT+=" --verbosity veryhigh" CLIENT+=" --control static --color false" CLIENT+=" --max-iterations 1" @@ -16,6 +23,7 @@ CLIENT_PID=$! SERVER="fairmq-ex-req-rep-server" SERVER+=" --id server" +SERVER+=" --transport $transport" SERVER+=" --verbosity veryhigh" SERVER+=" --control static --color false" SERVER+=" --max-iterations 1"