initialize method
Implementation
@override
Future<void> initialize() async {
final settings = ConnectionSettings(
host: _configHost,
port: _configPort,
tuningSettings: TuningSettings(
heartbeatPeriod: Duration(milliseconds: _heartbeatPeriod),
),
authProvider: PlainAuthenticator(
_configUser,
_configPassword,
),
);
_client = Client(settings: settings);
_logService.verbose('AMQP Broker Service initialized.', sender: 'DataHub');
}