Skip to content

Commit c8b352e

Browse files
chiarazampollidavidrohr
authored andcommitted
from push/pull to pub/sub to allow dropping messages in the aggregator
1 parent dcb934f commit c8b352e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

DATA/common/setenv_calib.sh

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,11 +143,11 @@ get_proxy_connection()
143143

144144
# setting the type of connection
145145
if [[ $2 == "input" ]]; then
146-
local CONNECTION="method=bind,type=pull"
146+
local CONNECTION="method=bind,type=sub"
147147
local NAMEPROXY="--proxy-name aggregator-proxy-$1"
148148
local NAMEPROXYCHANNEL=
149149
elif [[ $2 == "output" ]]; then
150-
local CONNECTION="method=connect,type=push"
150+
local CONNECTION="method=connect,type=pub"
151151
local NAMEPROXY="--proxy-name calib-output-proxy-$1"
152152
local NAMEPROXYCHANNEL="--proxy-channel-name aggregator-proxy-$1"
153153
else

0 commit comments

Comments
 (0)