initialize method

@override Future<void> initialize()

Implementation

@override
Future<void> initialize() async {
  final settings = ConnectionSettings(
    host: _configHost,
    port: _configPort,
    authProvider: PlainAuthenticator(
      _configUser,
      _configPassword,
    ),
  );

  _client = Client(settings: settings);
  _logService.verbose('AMQP Broker Service initialized.', sender: 'DataHub');
}