Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 16:46:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

all: apply fer-json-fmt

Browse Source
This commit is contained in:
Sebastien Binet 2016-11-10 15:20:09 +01:00 committed by Mohammad Al-Turany
parent 6e8839e955
commit e241ea41bb
7 changed files with 365 additions and 338 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
examples/MQ/1-sampler-sink/ex1-sampler-sink.json
View File

@ -1,40 +1,42 @@
{ {
"fairMQOptions": "fairMQOptions": {
{ "devices": [
"devices": {
[{ "id": "sampler1",
"id": "sampler1", "channels": [
"channels": {
[{ "name": "data",
"name": "data", "sockets": [
"sockets": {
[{ "type": "push",
"type": "push", "method": "bind",
"method": "bind", "address": "tcp://*:5555",
"address": "tcp://*:5555", "sndBufSize": 1000,
"sndBufSize": 1000, "rcvBufSize": 1000,
"rcvBufSize": 1000, "rateLogging": 0
"rateLogging": 0 }
}] ]
}] }
}, ]
},
{ {
"id": "sink1", "id": "sink1",
"channels": "channels": [
[{ {
"name": "data", "name": "data",
"sockets": "sockets": [
[{ {
"type": "pull", "type": "pull",
"method": "connect", "method": "connect",
"address": "tcp://localhost:5555", "address": "tcp://localhost:5555",
"sndBufSize": 1000, "sndBufSize": 1000,
"rcvBufSize": 1000, "rcvBufSize": 1000,
"rateLogging": 0 "rateLogging": 0
}] }
}] ]
}] }
]
}
]
} }
} }

129
examples/MQ/2-sampler-processor-sink/ex2-sampler-processor-sink.json
View File

@ -1,66 +1,73 @@
{ {
"fairMQOptions": "fairMQOptions": {
{ "devices": [
"devices": {
[{ "id": "sampler1",
"id": "sampler1", "channels": [
"channels": {
[{ "name": "data1",
"name": "data1", "sockets": [
"sockets": {
[{ "type": "push",
"type": "push", "method": "bind",
"method": "bind", "address": "tcp://*:5555",
"address": "tcp://*:5555", "sndBufSize": 1000,
"sndBufSize": 1000, "rcvBufSize": 1000,
"rcvBufSize": 1000, "rateLogging": 0
"rateLogging": 0 }
}] ]
}] }
}, ]
{
"key": "processor",
"channels":
[{
"name": "data1",
"sockets":
[{
"type": "pull",
"method": "connect",
"address": "tcp://localhost:5555",
"sndBufSize": 1000,
"rcvBufSize": 1000,
"rateLogging": 0
}]
}, },
{ {
"name": "data2", "key": "processor",
"sockets": "channels": [
[{ {
"type": "push", "name": "data1",
"method": "connect", "sockets": [
"address": "tcp://localhost:5556", {
"sndBufSize": 1000, "type": "pull",
"rcvBufSize": 1000, "method": "connect",
"rateLogging": 0 "address": "tcp://localhost:5555",
}] "sndBufSize": 1000,
}] "rcvBufSize": 1000,
}, "rateLogging": 0
{ }
"id": "sink1", ]
"channels": },
[{ {
"name": "data2", "name": "data2",
"sockets": "sockets": [
[{ {
"type": "pull", "type": "push",
"method": "bind", "method": "connect",
"address": "tcp://*:5556", "address": "tcp://localhost:5556",
"sndBufSize": 1000, "sndBufSize": 1000,
"rcvBufSize": 1000, "rcvBufSize": 1000,
"rateLogging": 0 "rateLogging": 0
}] }
}] ]
}] }
]
},
{
"id": "sink1",
"channels": [
{
"name": "data2",
"sockets": [
{
"type": "pull",
"method": "bind",
"address": "tcp://*:5556",
"sndBufSize": 1000,
"rcvBufSize": 1000,
"rateLogging": 0
}
]
}
]
}
]
} }
} }

73
examples/MQ/3-dds/ex3-dds.json
View File

@ -1,42 +1,41 @@
{ {
"fairMQOptions": "fairMQOptions": {
{ "devices": [
"devices": {
[{ "id": "sampler",
"id": "sampler", "channels": [
"channels": {
[{ "name": "data1",
"name": "data1", "type": "push",
"type": "push", "method": "bind"
"method": "bind", }
"rateLogging": 0 ]
}]
},
{
"key": "processor",
"channels":
[{
"name": "data1",
"type": "pull",
"method": "connect",
"rateLogging": 0
}, },
{ {
"name": "data2", "key": "processor",
"type": "push", "channels": [
"method": "connect", {
"rateLogging": 0 "name": "data1",
}] "type": "pull",
}, "method": "connect"
{ },
"id": "sink", {
"channels": "name": "data2",
[{ "type": "push",
"name": "data2", "method": "connect"
"type": "pull", }
"method": "bind", ]
"rateLogging": 0 },
}] {
}] "id": "sink",
"channels": [
{
"name": "data2",
"type": "pull",
"method": "bind"
}
]
}
]
} }
} }

125
examples/MQ/4-copypush/ex4-copypush.json
View File

@ -1,63 +1,68 @@
{ {
"fairMQOptions": "fairMQOptions": {
{ "devices": [
"devices": {
[{ "id": "sampler1",
"id": "sampler1", "channels": [
"channels": {
[{ "name": "data",
"name": "data", "sockets": [
"sockets": {
[{ "type": "push",
"type": "push", "method": "bind",
"method": "bind", "address": "tcp://*:5555",
"address": "tcp://*:5555", "sndBufSize": 1000,
"sndBufSize": 1000, "rcvBufSize": 1000,
"rcvBufSize": 1000, "rateLogging": 0
"rateLogging": 0 },
}, {
{ "type": "push",
"type": "push", "method": "bind",
"method": "bind", "address": "tcp://*:5556",
"address": "tcp://*:5556", "sndBufSize": 1000,
"sndBufSize": 1000, "rcvBufSize": 1000,
"rcvBufSize": 1000, "rateLogging": 0
"rateLogging": 0 }
}] ]
}] }
}, ]
{ },
"id": "sink1", {
"channels": "id": "sink1",
[{ "channels": [
"name": "data", {
"sockets": "name": "data",
[{ "sockets": [
"type": "pull", {
"method": "connect", "type": "pull",
"address": "tcp://localhost:5555", "method": "connect",
"sndBufSize": 1000, "address": "tcp://localhost:5555",
"rcvBufSize": 1000, "sndBufSize": 1000,
"rateLogging": 0 "rcvBufSize": 1000,
}] "rateLogging": 0
}] }
}, ]
{ }
"id": "sink2", ]
"channels": },
[{ {
"name": "data", "id": "sink2",
"sockets": "channels": [
[{ {
"type": "pull", "name": "data",
"method": "connect", "sockets": [
"address": "tcp://localhost:5556", {
"sndBufSize": 1000, "type": "pull",
"rcvBufSize": 1000, "method": "connect",
"rateLogging": 0 "address": "tcp://localhost:5556",
}] "sndBufSize": 1000,
}] "rcvBufSize": 1000,
}] "rateLogging": 0
}
]
}
]
}
]
} }
} }

75
examples/MQ/5-req-rep/ex5-req-rep.json
View File

@ -1,39 +1,42 @@
{ {
"fairMQOptions": "fairMQOptions": {
{ "devices": [
"devices": {
[{ "id": "client",
"id": "client", "channels": [
"channels": {
[{ "name": "data",
"name": "data", "sockets": [
"sockets": {
[{ "type": "req",
"type": "req", "method": "connect",
"method": "connect", "address": "tcp://localhost:5005",
"address": "tcp://localhost:5005", "sndBufSize": 1000,
"sndBufSize": 1000, "rcvBufSize": 1000,
"rcvBufSize": 1000, "rateLogging": 0
"rateLogging": 0 }
}] ]
}] }
}, ]
{ },
"id": "server", {
"channels": "id": "server",
[{ "channels": [
"name": "data", {
"sockets": "name": "data",
[{ "sockets": [
"type": "rep", {
"method": "bind", "type": "rep",
"address": "tcp://*:5005", "method": "bind",
"sndBufSize": 1000, "address": "tcp://*:5005",
"rcvBufSize": 1000, "sndBufSize": 1000,
"rateLogging": 0 "rcvBufSize": 1000,
}] "rateLogging": 0
}] }
}] ]
}
]
}
]
} }
} }

151
examples/MQ/6-multiple-channels/ex6-multiple-channels.json
View File

@ -1,79 +1,86 @@
{ {
"fairMQOptions": "fairMQOptions": {
{ "devices": [
"devices": {
[{ "id": "sampler1",
"id": "sampler1", "channels": [
"channels": {
[{ "name": "data",
"name": "data", "sockets": [
"sockets": {
[{ "type": "push",
"type": "push", "method": "bind",
"method": "bind", "address": "tcp://*:5555",
"address": "tcp://*:5555", "sndBufSize": 1000,
"sndBufSize": 1000, "rcvBufSize": 1000,
"rcvBufSize": 1000, "rateLogging": 0
"rateLogging": 0 }
}] ]
},
{
"name": "broadcast",
"sockets": [
{
"type": "sub",
"method": "connect",
"address": "tcp://localhost:5005",
"sndBufSize": 1000,
"rcvBufSize": 1000,
"rateLogging": 0
}
]
}
]
}, },
{ {
"name": "broadcast", "id": "sink1",
"sockets": "channels": [
[{ {
"type": "sub", "name": "data",
"method": "connect", "sockets": [
"address": "tcp://localhost:5005", {
"sndBufSize": 1000, "type": "pull",
"rcvBufSize": 1000, "method": "connect",
"rateLogging": 0 "address": "tcp://localhost:5555",
}] "sndBufSize": 1000,
}] "rcvBufSize": 1000,
}, "rateLogging": 0
{ }
"id": "sink1", ]
"channels": },
[{ {
"name": "data", "name": "broadcast",
"sockets": "sockets": [
[{ {
"type": "pull", "type": "sub",
"method": "connect", "method": "connect",
"address": "tcp://localhost:5555", "address": "tcp://localhost:5005",
"sndBufSize": 1000, "sndBufSize": 1000,
"rcvBufSize": 1000, "rcvBufSize": 1000,
"rateLogging": 0 "rateLogging": 0
}] }
]
}
]
}, },
{ {
"name": "broadcast", "id": "broadcaster1",
"sockets": "channels": [
[{ {
"type": "sub", "name": "broadcast",
"method": "connect", "sockets": [
"address": "tcp://localhost:5005", {
"sndBufSize": 1000, "type": "pub",
"rcvBufSize": 1000, "method": "bind",
"rateLogging": 0 "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
}]
}]
}]
} }
} }

74
examples/MQ/8-multipart/ex8-multipart.json
View File

@ -1,38 +1,42 @@
{ {
"fairMQOptions": "fairMQOptions": {
{ "devices": [
"devices": {
[{ "id": "sampler1",
"id": "sampler1", "channels": [
"channels": {
[{ "name": "data-out",
"name": "data-out", "sockets": [
"sockets": {
[{ "type": "push",
"type": "push", "method": "bind",
"method": "bind", "address": "tcp://*:5555",
"address": "tcp://*:5555", "sndBufSize": 1000,
"sndBufSize": 1000, "rcvBufSize": 1000,
"rcvBufSize": 1000, "rateLogging": 0
"rateLogging": 0 }
}] ]
}] }
}, ]
{ },
"id": "sink1", {
"channels": "id": "sink1",
[{ "channels": [
"name": "data-in", {
"sockets": "name": "data-in",
[{ "sockets": [
"type": "pull", {
"method": "connect", "type": "pull",
"address": "tcp://localhost:5555", "method": "connect",
"sndBufSize": 1000, "address": "tcp://localhost:5555",
"rcvBufSize": 1000, "sndBufSize": 1000,
"rateLogging": 0 "rcvBufSize": 1000,
}] "rateLogging": 0
}] }
}] ]
}
]
}
]
} }
} }