startConsuming abstract method

Future<void> startConsuming(
  1. String endpoint
)

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

Future<void> startConsuming(String endpoint);