startConsuming method
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();
}