Method maybeCleanupMessage

packages/cli/src/util/dev/queue-broker.ts:552–561

(messageId: string)

  }

  private maybeCleanupMessage(messageId: string): void {
    for (const groupDeliveries of this.deliveryState.values()) {
      if (groupDeliveries.has(messageId)) {
        return;
      }
    }

    // No group references it anymore, safe to remove
    this.messages.delete(messageId);
  }

  stop(): void {
    clearInterval(this.tickTimer);