haredo
    Preparing search index...

    Interface Adapter

    interface Adapter {
        emitter: TypedEventEmitter<AdapterEvents>;
        bindExchange(
            destination: string,
            source: string,
            routingKey?: string,
            args?: BindingArguments,
        ): Promise<void>;
        bindQueue(
            queueName: string,
            exchangeName: string,
            routingKey?: string,
            args?: BindingArguments,
        ): Promise<void>;
        close(force?: boolean): Promise<void>;
        connect(): Promise<void>;
        createExchange(
            name: string,
            type: string,
            options?: ExchangeParams,
            args?: ExchangeArguments,
        ): Promise<void>;
        createQueue(
            name: string | undefined,
            options?: QueueParams,
            args?: QueueArguments,
        ): Promise<string>;
        deleteExchange(
            name: string,
            options?: ExchangeDeleteOptions,
        ): Promise<void>;
        deleteQueue(name: string, options?: QueueDeleteOptions): Promise<void>;
        publish(
            exchange: string,
            routingKey: string,
            message: string,
            options: PublishOptions,
        ): Promise<void>;
        purgeQueue(name: string): Promise<void>;
        sendToQueue(
            name: string,
            message: string,
            options: PublishOptions,
        ): Promise<void>;
        subscribe(
            name: string,
            options: SubscribeOptions,
            callback: (message: HaredoMessage<unknown>) => Promise<void>,
        ): Promise<Consumer>;
        unbindExchange(
            destination: string,
            source: string,
            routingKey?: string,
            args?: BindingArguments,
        ): Promise<void>;
        unbindQueue(
            queueName: string,
            exchangeName: string,
            routingKey?: string,
            args?: BindingArguments,
        ): Promise<void>;
    }
    Index

    Properties

    emitter

    Methods

    bindExchange bindQueue close connect createExchange createQueue deleteExchange deleteQueue publish purgeQueue sendToQueue subscribe unbindExchange unbindQueue

    Properties

    emitter: TypedEventEmitter<AdapterEvents>

    Methods

    Settings

    Member Visibility

    On This Page

    Properties
    Methods