open method

@override Future open(String? correlationId)

Opens the component.

• correlationId (optional) transaction id to trace execution through call chain.

Implementation

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

  try {
    if (_autoSubscribe) {
      await subscribe(correlationId);
    }

    logger.debug(correlationId, 'Opened queue ' + getName());
  } catch (ex) {
    await close(correlationId);
  }
}