open method

@override Future open(String? correlationId)

Opens the component.

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

Implementation

@override
Future open(String? correlationId) async {
  if (_opened) {
    return null;
  }

  if (endpoint == null) {
    endpoint = _createEndpoint();
    endpoint!.register(this);
    _localEndpoint = true;
  }

  if (_localEndpoint) {
    await endpoint!.open(correlationId);
  }
  _opened = true;
}