initialize method

@override Future<void> initialize()

Implementation

@override
Future<void> initialize() async {
  final service = resolve<BrokerService?>();
  if (service == null) {
    _log.e('A BrokerService is required to start the EventHubService. '
        'Try providing a BrokerService implementation before this '
        'service to your ServiceHost.');
    throw Exception('No BrokerService found in ServiceHost.');
  }
  _brokerService = service;
  //TODO reconnect on channel disconnect
  _publishChannel = Lazy(() async => await _brokerService.openChannel()
    ..apply(_channels.add));
}