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? stateHandlers

Accessors

Methods

clearReconnect connect disconnect notifyHandlers notifyStateHandlers publish publishState scheduleReconnect setState subscribe subscribeState

Constructors

constructor

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

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

`Protected`stateHandlers

stateHandlers: Set<StateNotificationHandler> = ...

Accessors

state

get state(): NotificationChannelState
Current state of the channel

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

Methods

`Protected`clearReconnect

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

connect

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

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

disconnect

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

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

`Protected`notifyHandlers

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

`Protected`notifyStateHandlers

notifyStateHandlers(notification: JobStateNotification): Promise<void>
Notify all registered state handlers of a state notification. Subclasses should call this when receiving state notifications.
Parameters
- notification: JobStateNotification
Returns Promise<void>
Inherited from BaseNotificationChannel.notifyStateHandlers
- Defined in notifications/BaseNotificationChannel.ts:92

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:29

publishState

publishState(notification: JobStateNotification): Promise<void>
Parameters
- notification: JobStateNotification
Returns Promise<void>
- Defined in notifications/InMemoryNotificationChannel.ts:36

`Protected`scheduleReconnect

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

`Protected`setState

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

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:66

subscribeState

subscribeState(handler: StateNotificationHandler): () => void
Subscribe to state notifications. Default implementation manages the stateHandlers set.
Parameters
- handler: StateNotificationHandler
Returns () => void
Inherited from BaseNotificationChannel.subscribeState
- Defined in notifications/BaseNotificationChannel.ts:111