haredo
    Preparing search index...

    Interface HaredoInstance<E>

    interface HaredoInstance<E extends ExtensionInterface = object> {
        emitter: TypedEventEmitter<HaredoEvents>;
        close(force?: boolean): Promise<void>;
        connect(): Promise<void>;
        exchange<T = unknown>(
            exchange: ExchangeInterface<T>,
        ): ExchangeChain<T> & IterateExtension<E["exchange"], ExchangeChain<T>>;
        exchange<T = unknown>(
            exchange: string,
            type: ExchangeType,
            parameters?: ExchangeParams,
            args?: ExchangeArguments,
        ): ExchangeChain<T> & IterateExtension<E["exchange"], ExchangeChain<T>>;
        queue<T = unknown>(
            queue: QueueInterface<T>,
        ): QueueChain<T> & IterateExtension<E["queue"], QueueChain<T>>;
        queue<T = unknown>(
            queue: string,
            params?: QueueParams,
            args?: QueueArguments,
        ): QueueChain<T> & IterateExtension<E["queue"], QueueChain<T>>;
    }

    Type Parameters

    Index

    Properties

    emitter

    Methods

    close connect exchange queue

    Properties

    emitter: TypedEventEmitter<HaredoEvents>

    Methods

    • Cancel all consumers, wait for callbacks to finish and close the connection to the broker.

      Parameters

      • Optionalforce: boolean

      Returns Promise<void>

    Settings

    Member Visibility

    On This Page

    Properties
    Methods