getActiveBrokerEventConnector function

ActiveBrokerInterface getActiveBrokerEventConnector(
  1. AuthenticationManager authManager, {
  2. 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);
}