Interface NatsConnectionLike

Minimal NATS connection shape accepted by the transport.

interface NatsConnectionLike {
    close(): Promise<void>;
    publish(subject: string, payload: string): void;
    subscribe(
        subject: string,
        options?: { queue?: string },
    ): NatsSubscriptionLike;
}

Index

Methods

close publish subscribe

Methods

close

close(): Promise<void>
Close the NATS connection.

Returns Promise<void>
- Defined in packages/kkrpc/src/transports/nats.ts:32

publish

publish(subject: string, payload: string): void
Publish a payload on a subject.
Parameters
- subject: string
- payload: string
Returns void
- Defined in packages/kkrpc/src/transports/nats.ts:28

subscribe(subject: string, options?: { queue?: string }): NatsSubscriptionLike
Subscribe to a subject, optionally using a queue group.
Parameters
- subject: string
- Optionaloptions: { queue?: string }
Returns NatsSubscriptionLike
- Defined in packages/kkrpc/src/transports/nats.ts:30