diff --git a/examples/MQ/1-sampler-sink/ex1-sampler-sink.json b/examples/MQ/1-sampler-sink/ex1-sampler-sink.json index 06b7d8e3..8f85d3ec 100644 --- a/examples/MQ/1-sampler-sink/ex1-sampler-sink.json +++ b/examples/MQ/1-sampler-sink/ex1-sampler-sink.json @@ -1,40 +1,42 @@ { - "fairMQOptions": - { - "devices": - [{ - "id": "sampler1", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "push", - "method": "bind", - "address": "tcp://*:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - - { - "id": "sink1", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "pull", - "method": "connect", - "address": "tcp://localhost:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }] + "fairMQOptions": { + "devices": [ + { + "id": "sampler1", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "push", + "method": "bind", + "address": "tcp://*:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + }, + { + "id": "sink1", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "pull", + "method": "connect", + "address": "tcp://localhost:5555", + "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 7990caba..038383f7 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 @@ -1,66 +1,73 @@ { - "fairMQOptions": - { - "devices": - [{ - "id": "sampler1", - "channels": - [{ - "name": "data1", - "sockets": - [{ - "type": "push", - "method": "bind", - "address": "tcp://*:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "key": "processor", - "channels": - [{ - "name": "data1", - "sockets": - [{ - "type": "pull", - "method": "connect", - "address": "tcp://localhost:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] + "fairMQOptions": { + "devices": [ + { + "id": "sampler1", + "channels": [ + { + "name": "data1", + "sockets": [ + { + "type": "push", + "method": "bind", + "address": "tcp://*:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] }, { - "name": "data2", - "sockets": - [{ - "type": "push", - "method": "connect", - "address": "tcp://localhost:5556", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "id": "sink1", - "channels": - [{ - "name": "data2", - "sockets": - [{ - "type": "pull", - "method": "bind", - "address": "tcp://*:5556", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }] + "key": "processor", + "channels": [ + { + "name": "data1", + "sockets": [ + { + "type": "pull", + "method": "connect", + "address": "tcp://localhost:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + }, + { + "name": "data2", + "sockets": [ + { + "type": "push", + "method": "connect", + "address": "tcp://localhost:5556", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + }, + { + "id": "sink1", + "channels": [ + { + "name": "data2", + "sockets": [ + { + "type": "pull", + "method": "bind", + "address": "tcp://*:5556", + "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 a257aa97..efb88836 100644 --- a/examples/MQ/3-dds/ex3-dds.json +++ b/examples/MQ/3-dds/ex3-dds.json @@ -1,42 +1,41 @@ { - "fairMQOptions": - { - "devices": - [{ - "id": "sampler", - "channels": - [{ - "name": "data1", - "type": "push", - "method": "bind", - "rateLogging": 0 - }] - }, - { - "key": "processor", - "channels": - [{ - "name": "data1", - "type": "pull", - "method": "connect", - "rateLogging": 0 + "fairMQOptions": { + "devices": [ + { + "id": "sampler", + "channels": [ + { + "name": "data1", + "type": "push", + "method": "bind" + } + ] }, { - "name": "data2", - "type": "push", - "method": "connect", - "rateLogging": 0 - }] - }, - { - "id": "sink", - "channels": - [{ - "name": "data2", - "type": "pull", - "method": "bind", - "rateLogging": 0 - }] - }] + "key": "processor", + "channels": [ + { + "name": "data1", + "type": "pull", + "method": "connect" + }, + { + "name": "data2", + "type": "push", + "method": "connect" + } + ] + }, + { + "id": "sink", + "channels": [ + { + "name": "data2", + "type": "pull", + "method": "bind" + } + ] + } + ] } } diff --git a/examples/MQ/4-copypush/ex4-copypush.json b/examples/MQ/4-copypush/ex4-copypush.json index aa1004c1..68c8d349 100644 --- a/examples/MQ/4-copypush/ex4-copypush.json +++ b/examples/MQ/4-copypush/ex4-copypush.json @@ -1,63 +1,68 @@ { - "fairMQOptions": - { - "devices": - [{ - "id": "sampler1", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "push", - "method": "bind", - "address": "tcp://*:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }, - { - "type": "push", - "method": "bind", - "address": "tcp://*:5556", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "id": "sink1", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "pull", - "method": "connect", - "address": "tcp://localhost:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "id": "sink2", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "pull", - "method": "connect", - "address": "tcp://localhost:5556", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }] + "fairMQOptions": { + "devices": [ + { + "id": "sampler1", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "push", + "method": "bind", + "address": "tcp://*:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + }, + { + "type": "push", + "method": "bind", + "address": "tcp://*:5556", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + }, + { + "id": "sink1", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "pull", + "method": "connect", + "address": "tcp://localhost:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + }, + { + "id": "sink2", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "pull", + "method": "connect", + "address": "tcp://localhost:5556", + "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 72224a01..be5dd46c 100644 --- a/examples/MQ/5-req-rep/ex5-req-rep.json +++ b/examples/MQ/5-req-rep/ex5-req-rep.json @@ -1,39 +1,42 @@ { - "fairMQOptions": - { - "devices": - [{ - "id": "client", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "req", - "method": "connect", - "address": "tcp://localhost:5005", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "id": "server", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "rep", - "method": "bind", - "address": "tcp://*:5005", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }] + "fairMQOptions": { + "devices": [ + { + "id": "client", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "req", + "method": "connect", + "address": "tcp://localhost:5005", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + }, + { + "id": "server", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "rep", + "method": "bind", + "address": "tcp://*:5005", + "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 b2a57edf..5519ad6c 100644 --- a/examples/MQ/6-multiple-channels/ex6-multiple-channels.json +++ b/examples/MQ/6-multiple-channels/ex6-multiple-channels.json @@ -1,79 +1,86 @@ { - "fairMQOptions": - { - "devices": - [{ - "id": "sampler1", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "push", - "method": "bind", - "address": "tcp://*:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] + "fairMQOptions": { + "devices": [ + { + "id": "sampler1", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "push", + "method": "bind", + "address": "tcp://*:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + }, + { + "name": "broadcast", + "sockets": [ + { + "type": "sub", + "method": "connect", + "address": "tcp://localhost:5005", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] }, { - "name": "broadcast", - "sockets": - [{ - "type": "sub", - "method": "connect", - "address": "tcp://localhost:5005", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "id": "sink1", - "channels": - [{ - "name": "data", - "sockets": - [{ - "type": "pull", - "method": "connect", - "address": "tcp://localhost:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] + "id": "sink1", + "channels": [ + { + "name": "data", + "sockets": [ + { + "type": "pull", + "method": "connect", + "address": "tcp://localhost:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + }, + { + "name": "broadcast", + "sockets": [ + { + "type": "sub", + "method": "connect", + "address": "tcp://localhost:5005", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] }, { - "name": "broadcast", - "sockets": - [{ - "type": "sub", - "method": "connect", - "address": "tcp://localhost:5005", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "id": "broadcaster1", - "channels": - [{ - "name": "broadcast", - "sockets": - [{ - "type": "pub", - "method": "bind", - "address": "tcp://*:5005", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }] + "id": "broadcaster1", + "channels": [ + { + "name": "broadcast", + "sockets": [ + { + "type": "pub", + "method": "bind", + "address": "tcp://*:5005", + "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 6ba8339f..95fa1881 100644 --- a/examples/MQ/8-multipart/ex8-multipart.json +++ b/examples/MQ/8-multipart/ex8-multipart.json @@ -1,38 +1,42 @@ { - "fairMQOptions": - { - "devices": - [{ - "id": "sampler1", - "channels": - [{ - "name": "data-out", - "sockets": - [{ - "type": "push", - "method": "bind", - "address": "tcp://*:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }, - { - "id": "sink1", - "channels": - [{ - "name": "data-in", - "sockets": - [{ - "type": "pull", - "method": "connect", - "address": "tcp://localhost:5555", - "sndBufSize": 1000, - "rcvBufSize": 1000, - "rateLogging": 0 - }] - }] - }] + "fairMQOptions": { + "devices": [ + { + "id": "sampler1", + "channels": [ + { + "name": "data-out", + "sockets": [ + { + "type": "push", + "method": "bind", + "address": "tcp://*:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + }, + { + "id": "sink1", + "channels": [ + { + "name": "data-in", + "sockets": [ + { + "type": "pull", + "method": "connect", + "address": "tcp://localhost:5555", + "sndBufSize": 1000, + "rcvBufSize": 1000, + "rateLogging": 0 + } + ] + } + ] + } + ] } }