Method queueMessage

src/node/services/agentSession.ts:5041–5066

(
    message: string,
    options?: SendMessageOptions & { fileParts?: FilePart[] },
    internal?: {
      synthetic?: boolean;
      agentInitiated?: boolean;
      onAccepted?: () => Promise<void> | void;
      onAcceptedPreStreamFailure?: (error: SendMessageError) => Promise<void> | void;
      onCanceled?: (reason: string) => Promise<void> | void;
    }
  )

  }

  queueMessage(
    message: string,
    options?: SendMessageOptions & { fileParts?: FilePart[] },
    internal?: {
      synthetic?: boolean;
      agentInitiated?: boolean;
      onAccepted?: () => Promise<void> | void;
      onAcceptedPreStreamFailure?: (error: SendMessageError) => Promise<void> | void;
      onCanceled?: (reason: string) => Promise<void> | void;
    }
  ): "tool-end" | "turn-end" | null {
    this.assertNotDisposed("queueMessage");
    const didEnqueue = this.messageQueue.add(message, options, internal);
    if (!didEnqueue) {
      return null;
    }
    this.emitQueuedMessageChanged();
    // Signal to bash_output that it should return early to process queued messages
    // only for tool-end dispatches.
    const effectiveDispatchMode = this.messageQueue.getQueueDispatchMode();
    this.backgroundProcessManager.setMessageQueued(
      this.workspaceId,
      effectiveDispatchMode === "tool-end"
    );
    return effectiveDispatchMode;
  }

  clearQueue(cancelReason = "Queued message cleared before dispatch."): void {
    this.assertNotDisposed("clearQueue");