getActiveBrokerEventConnector function
ActiveBrokerInterface
getActiveBrokerEventConnector(
- AuthenticationManager authManager, {
- Map<
String, dynamic> args = const <String, dynamic>{},
Creates a new BrokerAmqpConnector configured to be used for the Event System.
See getActiveBrokerDefaultConnector for more information.
Implementation
ActiveBrokerInterface getActiveBrokerEventConnector(
AuthenticationManager authManager,
{Map<String, dynamic> args = const <String, dynamic>{}}) {
if (args.containsKey('exchangeName')) args['exchangeName'] = 'eventExchange';
if (args.containsKey('exchangeType'))
args['exchangeType'] = ExchangeType.TOPIC;
return getActiveBrokerDefaultConnector(authManager, args: args);
}