Class BrokerConnection

Hierarchy

RpcKernelBaseConnection
- BrokerConnection

Index

Constructors

Properties

connections locks replies state subscribedChannels

Methods

close onMessage sendEntityFields

Constructors

constructor

new BrokerConnection(transportWriter: RpcConnectionWriter, connections: RpcKernelConnections, state: BrokerState): BrokerConnection
Parameters
- transportWriter: RpcConnectionWriter
- connections: RpcKernelConnections
- state: BrokerState
Returns BrokerConnection
Overrides RpcKernelBaseConnection.constructor
- Defined in packages/broker/src/kernel.ts:34

Properties

`Protected` connections

connections: RpcKernelConnections

`Protected` locks

locks: Map<number, ProcessLock> = ...

`Protected` replies

replies: Map<number, ((message: RpcMessage) => void)> = ...

`Protected` state

state: BrokerState

`Protected` subscribedChannels

subscribedChannels: string[] = []

Methods

close

close(): void
Returns void
Overrides RpcKernelBaseConnection.close
- Defined in packages/broker/src/kernel.ts:42

onMessage

onMessage(message: RpcMessage, response: RpcMessageBuilder): Promise<void>
Parameters
- message: RpcMessage
- response: RpcMessageBuilder
Returns Promise<void>
Overrides RpcKernelBaseConnection.onMessage
- Defined in packages/broker/src/kernel.ts:66

`Protected` sendEntityFields

sendEntityFields(name: string): Promise<void>
Parameters
- name: string
Returns Promise<void>
- Defined in packages/broker/src/kernel.ts:54

Generated using TypeDoc