diff --git a/examples/MQ/1-sampler-sink/ex1-sampler-sink.json b/examples/MQ/1-sampler-sink/ex1-sampler-sink.json index c395ca12..06b7d8e3 100644 --- a/examples/MQ/1-sampler-sink/ex1-sampler-sink.json +++ b/examples/MQ/1-sampler-sink/ex1-sampler-sink.json @@ -4,36 +4,36 @@ "devices": [{ "id": "sampler1", - "channel": - { + "channels": + [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "push", "method": "bind", "address": "tcp://*:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }, { "id": "sink1", - "channel": - { + "channels": + [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "pull", "method": "connect", "address": "tcp://localhost:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }] } } diff --git a/examples/MQ/2-sampler-processor-sink/ex2-sampler-processor-sink.json b/examples/MQ/2-sampler-processor-sink/ex2-sampler-processor-sink.json index 7ff94836..7990caba 100644 --- a/examples/MQ/2-sampler-processor-sink/ex2-sampler-processor-sink.json +++ b/examples/MQ/2-sampler-processor-sink/ex2-sampler-processor-sink.json @@ -4,63 +4,63 @@ "devices": [{ "id": "sampler1", - "channel": - { + "channels": + [{ "name": "data1", - "socket": - { + "sockets": + [{ "type": "push", "method": "bind", "address": "tcp://*:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }, { "key": "processor", "channels": [{ "name": "data1", - "socket": - { + "sockets": + [{ "type": "pull", "method": "connect", "address": "tcp://localhost:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] }, { "name": "data2", - "socket": - { + "sockets": + [{ "type": "push", "method": "connect", "address": "tcp://localhost:5556", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] }] }, { "id": "sink1", - "channel": - { + "channels": + [{ "name": "data2", - "socket": - { + "sockets": + [{ "type": "pull", "method": "bind", "address": "tcp://*:5556", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }] } } diff --git a/examples/MQ/3-dds/ex3-dds.json b/examples/MQ/3-dds/ex3-dds.json index 6542370c..a257aa97 100644 --- a/examples/MQ/3-dds/ex3-dds.json +++ b/examples/MQ/3-dds/ex3-dds.json @@ -4,13 +4,13 @@ "devices": [{ "id": "sampler", - "channel": - { + "channels": + [{ "name": "data1", "type": "push", "method": "bind", - "rateLogging": "0" - } + "rateLogging": 0 + }] }, { "key": "processor", @@ -19,24 +19,24 @@ "name": "data1", "type": "pull", "method": "connect", - "rateLogging": "0" + "rateLogging": 0 }, { "name": "data2", "type": "push", "method": "connect", - "rateLogging": "0" + "rateLogging": 0 }] }, { "id": "sink", - "channel": - { + "channels": + [{ "name": "data2", "type": "pull", "method": "bind", - "rateLogging": "0" - } + "rateLogging": 0 + }] }] } } diff --git a/examples/MQ/4-copypush/ex4-copypush.json b/examples/MQ/4-copypush/ex4-copypush.json index 608d4a7c..aa1004c1 100644 --- a/examples/MQ/4-copypush/ex4-copypush.json +++ b/examples/MQ/4-copypush/ex4-copypush.json @@ -4,59 +4,59 @@ "devices": [{ "id": "sampler1", - "channel": - { + "channels": + [{ "name": "data", "sockets": [{ "type": "push", "method": "bind", "address": "tcp://*:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 }, { "type": "push", "method": "bind", "address": "tcp://*:5556", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 }] - } + }] }, { "id": "sink1", - "channel": - { + "channels": + [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "pull", "method": "connect", "address": "tcp://localhost:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }, { "id": "sink2", - "channel": - { + "channels": + [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "pull", "method": "connect", "address": "tcp://localhost:5556", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }] } } diff --git a/examples/MQ/5-req-rep/ex5-req-rep.json b/examples/MQ/5-req-rep/ex5-req-rep.json index e2006a65..72224a01 100644 --- a/examples/MQ/5-req-rep/ex5-req-rep.json +++ b/examples/MQ/5-req-rep/ex5-req-rep.json @@ -4,35 +4,35 @@ "devices": [{ "id": "client", - "channel": - { + "channels": + [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "req", "method": "connect", "address": "tcp://localhost:5005", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }, { "id": "server", - "channel": - { + "channels": + [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "rep", "method": "bind", "address": "tcp://*:5005", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }] } } diff --git a/examples/MQ/6-multiple-channels/ex6-multiple-channels.json b/examples/MQ/6-multiple-channels/ex6-multiple-channels.json index e93c84cb..b2a57edf 100644 --- a/examples/MQ/6-multiple-channels/ex6-multiple-channels.json +++ b/examples/MQ/6-multiple-channels/ex6-multiple-channels.json @@ -7,27 +7,27 @@ "channels": [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "push", "method": "bind", "address": "tcp://*:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] }, { "name": "broadcast", - "socket": - { + "sockets": + [{ "type": "sub", "method": "connect", "address": "tcp://localhost:5005", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] }] }, { @@ -35,44 +35,44 @@ "channels": [{ "name": "data", - "socket": - { + "sockets": + [{ "type": "pull", "method": "connect", "address": "tcp://localhost:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] }, { "name": "broadcast", - "socket": - { + "sockets": + [{ "type": "sub", "method": "connect", "address": "tcp://localhost:5005", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] }] }, { "id": "broadcaster1", - "channel": - { + "channels": + [{ "name": "broadcast", - "socket": - { + "sockets": + [{ "type": "pub", "method": "bind", "address": "tcp://*:5005", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }] } } diff --git a/examples/MQ/8-multipart/ex8-multipart.json b/examples/MQ/8-multipart/ex8-multipart.json index 3638e614..6ba8339f 100644 --- a/examples/MQ/8-multipart/ex8-multipart.json +++ b/examples/MQ/8-multipart/ex8-multipart.json @@ -4,35 +4,35 @@ "devices": [{ "id": "sampler1", - "channel": - { + "channels": + [{ "name": "data-out", - "socket": - { + "sockets": + [{ "type": "push", "method": "bind", "address": "tcp://*:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }, { "id": "sink1", - "channel": - { + "channels": + [{ "name": "data-in", - "socket": - { + "sockets": + [{ "type": "pull", "method": "connect", "address": "tcp://localhost:5555", - "sndBufSize": "1000", - "rcvBufSize": "1000", - "rateLogging": "0" - } - } + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }] + }] }] } }