haredo

    Interface SharedChain

    interface SharedChain {
        json(autoSerialize?: boolean): this;
        setup(): Promise<void>;
        skipSetup(options?: boolean | SkipSetupOptions): this;
        unbindExchange(
            name: string,
            routingKey: string | string[],
            bindingArguments?: BindingArguments,
        ): Promise<void>;
        unbindExchange(
            name: ExchangeInterface,
            routingKey: string | string[],
            bindingArguments?: BindingArguments,
        ): Promise<void>;
    }

    Hierarchy (View Summary, Expand)

    Index

    Methods

    • 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

    • Set up the topology declared in the chain. All exchanges / queues / bindings will be created.

      Returns Promise<void>

    • Skip setup of the topology declared in the chain. Normally all queues / exchanges / bindings will be created each time subscribe / publish is called. This method will skip that step.

      Parameters

      Returns this

    MMNEPVFCICPMFPCPTTAAATR