subscribe method
Register a handler
to subscribe to messages sent to the topic.
Implementation
Future<void> subscribe(MessageHandler middleware) async {
var registrationRequest = $tp.RegistrationRequest(topicName: name);
var worker = SubscriptionWorker(registrationRequest, middleware,
client: _subscriberClient);
await worker.start();
}