Generic Event Channel subscriber

Overview

rtctkGenEventSub is a troubleshooting tool used to subscribe to an Event Channel topic.

It can be used to subscribe to an Event Channel topic, and receives events published by Event Channel publishers. Together with Generic Event Channel publisher, it can be used to verify if events published on other machines can received by the machine where the subscriber is running.

Running

The generic Event Channel subscriber is run by executing: rtctkGenEventSub with the proper command line arguments. For a list of command line options, run the executable with option -h.

E.g. run the subscriber that receives 100 events (or timeouts) from test_ec and prints the payload to stdout.

$ rtctkGenEventSub -n 100 test_ec

Receiving events is indicated with a message like:

subscribed
callback: 1 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 2 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 3 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 4 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 5 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 6 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 7 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 8 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 9 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 10 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 11 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 12 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 13 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 14 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 15 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 16 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 17 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 18 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 19 {"origin":"test_source","time":123,"type":["TestType"]}
callback: 20 {"origin":"test_source","time":123,"type":["TestType"]}
...

And after it is done with a message like:

unsubscribed

Stopping

The process stops after receiving given number of events, upon timeout, or it can be stopped using Ctrl-C.