startConsuming method

  1. @override
void startConsuming(
  1. String endpoint
)
override

Starts consuming on the endpoint.

The endpoints should be in the correct format (s3ib://s3i:+ UUIDv4 for decrypted communication or s3ibs://s3i: + UUIDv4 for encrypted messages).

Implementation

@override
void startConsuming(String endpoint) {
  _endpoints.add(endpoint);
  if (!_enablePolling) _startPolling();
}