Class InMemoryNotificationChannel

In-memory notification channel for testing and single-process scenarios. Notifications are delivered synchronously within the same process.

Hierarchy (View Summary)

BaseNotificationChannel
- InMemoryNotificationChannel

Index

Constructors

Properties

_state config handlers reconnectAttempts reconnectTimeout?

Accessors

Methods

clearReconnect connect disconnect notifyHandlers publish scheduleReconnect setState subscribe

Constructors

constructor

new InMemoryNotificationChannel(
config?: NotificationChannelConfig,
): InMemoryNotificationChannel
Parameters
- config: NotificationChannelConfig = {}
Returns InMemoryNotificationChannel
Overrides BaseNotificationChannel.constructor
- Defined in notifications/InMemoryNotificationChannel.ts:12

Properties

`Protected`_state

_state: NotificationChannelState = 'disconnected'

`Protected` `Readonly`config

config: ResolvedNotificationChannelConfig

`Protected`handlers

handlers: Set<NotificationHandler> = ...

`Protected`reconnectAttempts

reconnectAttempts: number = 0

`Protected` `Optional`reconnectTimeout

reconnectTimeout?: Timeout

Accessors

state

get state(): NotificationChannelState
Current state of the channel

Returns NotificationChannelState
Inherited from BaseNotificationChannel.state
- Defined in notifications/BaseNotificationChannel.ts:48

Methods

`Protected`clearReconnect

clearReconnect(): void
Returns void
Inherited from BaseNotificationChannel.clearReconnect
- Defined in notifications/BaseNotificationChannel.ts:111

connect

connect(): Promise<void>
Connect to the notification backend

Returns Promise<void>
Overrides BaseNotificationChannel.connect
- Defined in notifications/InMemoryNotificationChannel.ts:16

disconnect

disconnect(): Promise<void>
Disconnect from the notification backend

Returns Promise<void>
Overrides BaseNotificationChannel.disconnect
- Defined in notifications/InMemoryNotificationChannel.ts:21

`Protected`notifyHandlers

notifyHandlers(notification: JobNotification): Promise<void>
Parameters
- notification: JobNotification
Returns Promise<void>
Inherited from BaseNotificationChannel.notifyHandlers
- Defined in notifications/BaseNotificationChannel.ts:70

publish

publish(notification: JobNotification): Promise<void>
Publish a job notification
Parameters
- notification: JobNotification
  The notification to publish
Returns Promise<void>
Overrides BaseNotificationChannel.publish
- Defined in notifications/InMemoryNotificationChannel.ts:27

`Protected`scheduleReconnect

scheduleReconnect(): void
Returns void
Inherited from BaseNotificationChannel.scheduleReconnect
- Defined in notifications/BaseNotificationChannel.ts:85

`Protected`setState

setState(newState: NotificationChannelState): void
Parameters
- newState: NotificationChannelState
Returns void
Inherited from BaseNotificationChannel.setState
- Defined in notifications/BaseNotificationChannel.ts:52

subscribe(handler: NotificationHandler): () => void
Subscribe to job notifications
Parameters
- handler: NotificationHandler
  Function to call when a notification is received
Returns () => void
Unsubscribe function
Inherited from BaseNotificationChannel.subscribe
- Defined in notifications/BaseNotificationChannel.ts:63