Added a simple Worker class to process the incoming requests and send back the response. The publish sends data on the input channel, the subscribe subscribes on the output channel. It is a basic req-rep pattern, I'll develop it further...