From c86bfd97a89a3c27ac1dc7b377bd4c88383dcb6a Mon Sep 17 00:00:00 2001 From: mkrzewic Date: Fri, 11 Nov 2016 17:06:07 +0100 Subject: [PATCH] Update MQ example 8 to use multiple endpoints --- examples/MQ/8-multipart/ex8-multipart.json | 24 +++++++++++++++++++--- 1 file changed, 21 insertions(+), 3 deletions(-) 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