clear method

@override Future clear(String? correlationId)

Clears component state.

• correlationId (optional) transaction id to trace execution through call chain. Return Future that receives null no errors occured. Throws error

Implementation

@override
Future clear(String? correlationId) async {
  _messages = <MessageEnvelope>[];
  _lockedMessages = <int, LockedMessage>{};
  _cancel = false;
}