Class PgNotifyServer

Hierarchy

  • Server
    • PgNotifyServer

Implements

  • CustomTransportStrategy

Constructors

constructor

Properties

deserializer firstConnected logger loggerService messageHandlers serializer subscriber

Methods

addHandler bindEventHandlers bindMessageHandlers close createClient getHandlerByPattern getHandlers getOptionsProp getPublisher getResponse getRouteFromPattern handleAsEvent handleAsRequest handleError handleEvent initializeDeserializer initializeSerializer listen listenChannels loadPackage normalizePattern parsePayload send transformToObservable

Constructors

constructor

Properties

Protected deserializer

deserializer: ConsumerDeserializer

Private firstConnected

firstConnected: boolean

Protected Readonly logger

logger: LoggerService

Private Readonly loggerService

loggerService: LoggerService

Protected Readonly messageHandlers

messageHandlers: Map<string, MessageHandler<any, any, any>>

Protected serializer

serializer: ConsumerSerializer

Private Readonly subscriber

subscriber: Subscriber<{ [channel: string]: any }>

Methods

addHandler

  • Parameters

    • pattern: string | Record<string, any>
    • callback: MessageHandler<any, any, any>

    Returns void

Private bindEventHandlers

  • Parameters

    • subscriber: Subscriber<{ [channel: string]: any }>

    Returns void

Private bindMessageHandlers

  • Returns void

close

  • Returns Promise<void>

Private createClient

  • Parameters

    Returns Subscriber<{ [channel: string]: any }>

getHandlerByPattern

  • Parameters

    • pattern: string

    Returns null | MessageHandler<any, any, any>

getHandlers

  • Returns Map<string, MessageHandler<any, any, any>>

getOptionsProp

  • Type Parameters

    • T extends undefined | {} | { deserializer?: Deserializer<any, any>; retryAttempts?: number; retryDelay?: number; serializer?: Serializer<any, any>; url?: string } & IORedisOptions | { authenticator?: any; debug?: boolean; deserializer?: Deserializer<any, any>; encoding?: string; headers?: Record<string, string>; ignoreClusterUpdates?: boolean; inboxPrefix?: string; maxPingOut?: number; maxReconnectAttempts?: number; name?: string; nkey?: any; noEcho?: boolean; noRandomize?: boolean; nonceSigner?: any; pass?: string; pedantic?: boolean; pingInterval?: number; preserveBuffers?: boolean; queue?: string; reconnect?: boolean; reconnectDelayHandler?: any; reconnectJitter?: number; reconnectJitterTLS?: number; reconnectTimeWait?: number; serializer?: Serializer<any, any>; servers?: string | string[]; timeout?: number; tls?: any; token?: string; tokenHandler?: any; useOldRequestStyle?: boolean; user?: string; userCreds?: any; userJWT?: string; verbose?: boolean; waitOnFirstConnect?: boolean; yieldTime?: number; [key: string]: any } | MqttClientOptions & { deserializer?: Deserializer<any, any>; serializer?: Serializer<any, any>; subscribeOptions?: { nl?: boolean; qos: QoS; rap?: boolean; rh?: number }; url?: string; userProperties?: Record<string, string | string[]> } | { channelOptions?: ChannelOptions; credentials?: any; keepalive?: { http2MaxPingStrikes?: number; http2MaxPingsWithoutData?: number; http2MinPingIntervalWithoutDataMs?: number; http2MinTimeBetweenPingsMs?: number; keepalivePermitWithoutCalls?: number; keepaliveTimeMs?: number; keepaliveTimeoutMs?: number }; loader?: { alternateCommentMode?: boolean; arrays?: boolean; bytes?: Function; defaults?: boolean; enums?: Function; includeDirs?: string[]; json?: boolean; keepCase?: boolean; longs?: Function; objects?: boolean; oneofs?: boolean }; maxMetadataSize?: number; maxReceiveMessageLength?: number; maxSendMessageLength?: number; package: string | string[]; packageDefinition?: any; protoLoader?: string; protoPath: string | string[]; url?: string } | { client?: KafkaConfig; consumer?: ConsumerConfig; deserializer?: Deserializer<any, any>; parser?: KafkaParserConfig; postfixId?: string; producer?: ProducerConfig; producerOnlyMode?: boolean; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; send?: Omit<ProducerRecord, "topic" | "messages">; serializer?: Serializer<any, any>; subscribe?: Omit<ConsumerSubscribeTopic, "topic"> } | { deserializer?: Deserializer<any, any>; headers?: Record<string, string>; isGlobalPrefetchCount?: boolean; noAck?: boolean; persistent?: boolean; prefetchCount?: number; queue?: string; queueOptions?: any; replyQueue?: string; serializer?: Serializer<any, any>; socketOptions?: any; urls?: string[] | RmqUrl[] } | { deserializer?: Deserializer<any, any>; host?: string; port?: number; retryAttempts?: number; retryDelay?: number; serializer?: Serializer<any, any>; socketClass?: Type<TcpSocket> }

    • K extends string | number | symbol

    Parameters

    • obj: T
    • prop: K
    • Optional defaultValue: T[K]

    Returns T[K]

Private getPublisher

  • Parameters

    • pattern: string
    • id: string

    Returns ((response: any) => Promise<any>)

      • (response: any): Promise<any>

      • Parameters

        • response: any

        Returns Promise<any>

Private getResponse

Protected getRouteFromPattern

  • Transforms the server Pattern to valid type and returns a route for him.

    Returns

    string

    Parameters

    • pattern: string

      server pattern

    Returns string

Private handleAsEvent

  • Parameters

    Returns Promise<void>

Private handleAsRequest

  • Parameters

    Returns Promise<Subscription>

Protected handleError

  • Parameters

    • error: string

    Returns void

handleEvent

  • Parameters

    • pattern: string
    • packet: ReadPacket<any>
    • context: BaseRpcContext<unknown[]>

    Returns Promise<any>

Protected initializeDeserializer

  • Parameters

    • options: undefined | { deserializer?: Deserializer<any, any>; retryAttempts?: number; retryDelay?: number; serializer?: Serializer<any, any>; url?: string } & IORedisOptions | { authenticator?: any; debug?: boolean; deserializer?: Deserializer<any, any>; encoding?: string; headers?: Record<string, string>; ignoreClusterUpdates?: boolean; inboxPrefix?: string; maxPingOut?: number; maxReconnectAttempts?: number; name?: string; nkey?: any; noEcho?: boolean; noRandomize?: boolean; nonceSigner?: any; pass?: string; pedantic?: boolean; pingInterval?: number; preserveBuffers?: boolean; queue?: string; reconnect?: boolean; reconnectDelayHandler?: any; reconnectJitter?: number; reconnectJitterTLS?: number; reconnectTimeWait?: number; serializer?: Serializer<any, any>; servers?: string | string[]; timeout?: number; tls?: any; token?: string; tokenHandler?: any; useOldRequestStyle?: boolean; user?: string; userCreds?: any; userJWT?: string; verbose?: boolean; waitOnFirstConnect?: boolean; yieldTime?: number; [key: string]: any } | MqttClientOptions & { deserializer?: Deserializer<any, any>; serializer?: Serializer<any, any>; subscribeOptions?: { nl?: boolean; qos: QoS; rap?: boolean; rh?: number }; url?: string; userProperties?: Record<string, string | string[]> } | { channelOptions?: ChannelOptions; credentials?: any; keepalive?: { http2MaxPingStrikes?: number; http2MaxPingsWithoutData?: number; http2MinPingIntervalWithoutDataMs?: number; http2MinTimeBetweenPingsMs?: number; keepalivePermitWithoutCalls?: number; keepaliveTimeMs?: number; keepaliveTimeoutMs?: number }; loader?: { alternateCommentMode?: boolean; arrays?: boolean; bytes?: Function; defaults?: boolean; enums?: Function; includeDirs?: string[]; json?: boolean; keepCase?: boolean; longs?: Function; objects?: boolean; oneofs?: boolean }; maxMetadataSize?: number; maxReceiveMessageLength?: number; maxSendMessageLength?: number; package: string | string[]; packageDefinition?: any; protoLoader?: string; protoPath: string | string[]; url?: string } | { client?: KafkaConfig; consumer?: ConsumerConfig; deserializer?: Deserializer<any, any>; parser?: KafkaParserConfig; postfixId?: string; producer?: ProducerConfig; producerOnlyMode?: boolean; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; send?: Omit<ProducerRecord, "topic" | "messages">; serializer?: Serializer<any, any>; subscribe?: Omit<ConsumerSubscribeTopic, "topic"> } | { deserializer?: Deserializer<any, any>; host?: string; port?: number; serializer?: Serializer<any, any>; socketClass?: Type<TcpSocket> } | { deserializer?: Deserializer<any, any>; headers?: Record<string, string>; isGlobalPrefetchCount?: boolean; noAck?: boolean; persistent?: boolean; prefetchCount?: number; queue?: string; queueOptions?: any; replyQueue?: string; serializer?: Serializer<any, any>; socketOptions?: any; urls?: string[] | RmqUrl[] }

    Returns void

Protected initializeSerializer

  • Parameters

    • options: undefined | { deserializer?: Deserializer<any, any>; retryAttempts?: number; retryDelay?: number; serializer?: Serializer<any, any>; url?: string } & IORedisOptions | { authenticator?: any; debug?: boolean; deserializer?: Deserializer<any, any>; encoding?: string; headers?: Record<string, string>; ignoreClusterUpdates?: boolean; inboxPrefix?: string; maxPingOut?: number; maxReconnectAttempts?: number; name?: string; nkey?: any; noEcho?: boolean; noRandomize?: boolean; nonceSigner?: any; pass?: string; pedantic?: boolean; pingInterval?: number; preserveBuffers?: boolean; queue?: string; reconnect?: boolean; reconnectDelayHandler?: any; reconnectJitter?: number; reconnectJitterTLS?: number; reconnectTimeWait?: number; serializer?: Serializer<any, any>; servers?: string | string[]; timeout?: number; tls?: any; token?: string; tokenHandler?: any; useOldRequestStyle?: boolean; user?: string; userCreds?: any; userJWT?: string; verbose?: boolean; waitOnFirstConnect?: boolean; yieldTime?: number; [key: string]: any } | MqttClientOptions & { deserializer?: Deserializer<any, any>; serializer?: Serializer<any, any>; subscribeOptions?: { nl?: boolean; qos: QoS; rap?: boolean; rh?: number }; url?: string; userProperties?: Record<string, string | string[]> } | { channelOptions?: ChannelOptions; credentials?: any; keepalive?: { http2MaxPingStrikes?: number; http2MaxPingsWithoutData?: number; http2MinPingIntervalWithoutDataMs?: number; http2MinTimeBetweenPingsMs?: number; keepalivePermitWithoutCalls?: number; keepaliveTimeMs?: number; keepaliveTimeoutMs?: number }; loader?: { alternateCommentMode?: boolean; arrays?: boolean; bytes?: Function; defaults?: boolean; enums?: Function; includeDirs?: string[]; json?: boolean; keepCase?: boolean; longs?: Function; objects?: boolean; oneofs?: boolean }; maxMetadataSize?: number; maxReceiveMessageLength?: number; maxSendMessageLength?: number; package: string | string[]; packageDefinition?: any; protoLoader?: string; protoPath: string | string[]; url?: string } | { client?: KafkaConfig; consumer?: ConsumerConfig; deserializer?: Deserializer<any, any>; parser?: KafkaParserConfig; postfixId?: string; producer?: ProducerConfig; producerOnlyMode?: boolean; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; send?: Omit<ProducerRecord, "topic" | "messages">; serializer?: Serializer<any, any>; subscribe?: Omit<ConsumerSubscribeTopic, "topic"> } | { deserializer?: Deserializer<any, any>; host?: string; port?: number; serializer?: Serializer<any, any>; socketClass?: Type<TcpSocket> } | { deserializer?: Deserializer<any, any>; headers?: Record<string, string>; isGlobalPrefetchCount?: boolean; noAck?: boolean; persistent?: boolean; prefetchCount?: number; queue?: string; queueOptions?: any; replyQueue?: string; serializer?: Serializer<any, any>; socketOptions?: any; urls?: string[] | RmqUrl[] }

    Returns void

listen

  • Parameters

    • callback: (() => void)
        • (): void

        • Returns void

    Returns Promise<void>

Private listenChannels

  • Returns Promise<void>

Protected loadPackage

  • Type Parameters

    • T = any

    Parameters

    • name: string
    • ctx: string
    • Optional loader: Function

    Returns T

Protected normalizePattern

  • Parameters

    • pattern: MsPattern

    Returns string

Private parsePayload

  • Parameters

    • payload: any

    Returns { data: any; id?: string }

    • data: any
    • Optional id?: string

send

  • Parameters

    • stream$: Observable<any>
    • respond: ((data: WritePacket<any>) => unknown)
        • (data: WritePacket<any>): unknown

        • Parameters

          • data: WritePacket<any>

          Returns unknown

    Returns Subscription

transformToObservable

  • Type Parameters

    • T

    Parameters

    • resultOrDeferred: Observable<T> | Promise<T>

    Returns Observable<T>

  • Type Parameters

    • T

    Parameters

    • resultOrDeferred: T

    Returns Observable<T>

Settings

Member Visibility

Theme

Generated using TypeDoc