diff --git a/examples/MQ/8-multipart/ex8-multipart.json b/examples/MQ/8-multipart/ex8-multipart.json index 95fa1881..92a99032 100644 --- a/examples/MQ/8-multipart/ex8-multipart.json +++ b/examples/MQ/8-multipart/ex8-multipart.json @@ -9,8 +9,8 @@ "sockets": [ { "type": "push", - "method": "bind", - "address": "tcp://*:5555", + "method": "connect", + "address": "tcp://localhost:5555,tcp://localhost:5556", "sndBufSize": 1000, "rcvBufSize": 1000, "rateLogging": 0 @@ -21,6 +21,24 @@ }, { "id": "sink1", + "channels": [ + { + "name": "data-in", + "sockets": [ + { + "type": "pull", + "method": "bind", + "address": "tcp://*:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + }, + { + "id": "sink2", "channels": [ { "name": "data-in", @@ -28,7 +46,7 @@ { "type": "pull", "method": "connect", - "address": "tcp://localhost:5555", + "address": "@tcp://*:5556", "sndBufSize": 1000, "rcvBufSize": 1000, "rateLogging": 0