haredo

    Interface ExchangeChain<T>

    interface ExchangeChain<T = unknown> {
        bindExchange(
            sourceExchange: string,
            routingKey: string | string[],
            type: ExchangeType,
            exchangeParams?: ExchangeParams,
            exchangeArguments?: ExchangeArguments,
            bindingArguments?: BindingArguments,
        ): ExchangeChain<T>;
        bindExchange(
            sourceExchange: ExchangeInterface,
            routingKey: string | string[],
            bindingArguments?: BindingArguments,
        ): ExchangeChain<T>;
        confirm(): this;
        delay(milliseconds: number): ExchangeChain<T>;
        delete(options?: ExchangeDeleteOptions): Promise<void>;
        expiration(milliseconds: number): this;
        json(autoSerialize?: boolean): this;
        priority(priority: number): this;
        publish(message: T, routingKey: string): Promise<void>;
        setArgument<K extends keyof AMQPProperties>(
            key: K,
            value: AMQPProperties[K],
        ): ExchangeChain<T>;
        setHeader(key: string, value: Field): this;
        setup(): Promise<void>;
        skipSetup(options?: boolean | SkipSetupOptions): this;
        type(type: string): this;
        unbindExchange(
            name: string,
            routingKey: string | string[],
            bindingArguments?: BindingArguments,
        ): Promise<void>;
        unbindExchange(
            name: ExchangeInterface,
            routingKey: string | string[],
            bindingArguments?: BindingArguments,
        ): Promise<void>;
    }

    Type Parameters

    • T = unknown

    Hierarchy (View Summary, Expand)

    Index

    Methods

    bindExchange confirm delay delete expiration json priority publish setArgument setHeader setup skipSetup type unbindExchange

    Methods

    • Set the publish to use confirm mode. This will make the publish method return a promise that will resolve when the message has been confirmed as received by the broker.

      Returns this

    • Set the message expiration time in milliseconds

      Parameters

      • milliseconds: number

      Returns this

    • Always serialize messages as JSON. This will make the publish method always serialize the message as JSON before sending it to the broker. The subscribe method will always deserialize the message as JSON before passing it to the callback.

      Parameters

      • OptionalautoSerialize: boolean

      Returns this

    • Publish a message to the exchange. Unless .json(false) has been called the message will be serialized as JSON before being sent to the broker.

      Parameters

      • message: T
      • routingKey: string

      Returns Promise<void>

    Settings

    Member Visibility

    On This Page

    Methods
    MMNEPVFCICPMFPCPTTAAATR