Interface NotificationConsumer

Notification consumer configuration for PostgreSQL stream provider. Manages notification-based message consumption with fallback polling.

interface NotificationConsumer {
    callback: ((messages: StreamMessage[]) => void);
    consumerName: string;
    fetchInFlight?: boolean;
    fetchPending?: boolean;
    groupName: string;
    isListening: boolean;
    lastFallbackCheck: number;
    serviceInstance?: any;
    streamName: string;
}

Properties

callback consumerName fetchInFlight? fetchPending? groupName isListening lastFallbackCheck serviceInstance? streamName

Properties

callback

callback: ((messages: StreamMessage[]) => void)

Callback function invoked when messages are available

consumerName

consumerName: string

Unique name identifying this consumer

OptionalfetchInFlight

fetchInFlight?: boolean

True while a notification-driven fetch is in flight (coalesces concurrent NOTIFYs)

OptionalfetchPending

fetchPending?: boolean

Set when a NOTIFY arrives mid-fetch; triggers one follow-up fetch

groupName

groupName: string

Name of the consumer group

isListening

isListening: boolean

Whether this consumer is actively listening for notifications

lastFallbackCheck

lastFallbackCheck: number

Timestamp of the last fallback check (used for periodic polling)

OptionalserviceInstance

serviceInstance?: any

Service instance that owns this consumer (for fetchAndDeliverMessages dispatch)

streamName

streamName: string

Name of the stream being consumed

Settings

Member Visibility

On This Page

Properties