Skip to content

UdpSocketActor

Defined in: src/io/broker/UdpSocketActor.ts:42

UDP-socket actor. Uses node:dgram (built-in everywhere). No connection lifecycle in the TCP sense; we treat “bound” as connected and “unbound” as disconnected, so the base class’ lifecycle events still apply (BrokerConnected fires once the socket is bound).

new UdpSocketActor(settings?): UdpSocketActor

Defined in: src/io/broker/UdpSocketActor.ts:47

Partial<UdpSocketActorSettings> = {}

UdpSocketActor

BrokerActor<UdpSocketActorSettings, UdpSocketCmd, UdpOutbound>.constructor

get boundPort(): number

Defined in: src/io/broker/UdpSocketActor.ts:68

OS-assigned port after bind (0 before, real number after).

number

onReceive(cmd): void

Defined in: src/io/broker/UdpSocketActor.ts:123

Main message handler. Receives each envelope dequeued from the mailbox. A thrown error (sync or async) is caught by the supervisor.

UdpSocketCmd

void

BrokerActor.onReceive


postRestart(_reason): void | Promise<void>

Defined in: src/Actor.ts:55

Called on the fresh instance after a restart. Default: call preStart().

Error

void | Promise<void>

BrokerActor.postRestart


postStop(): Promise<void>

Defined in: src/io/broker/BrokerActor.ts:241

Called after the actor has been terminated. Children are already stopped.

Promise<void>

BrokerActor.postStop


preRestart(_reason, _message?): void | Promise<void>

Defined in: src/Actor.ts:50

Called before a restart, on the instance about to be thrown away. The default stops children and then calls postStop().

Error

UdpSocketCmd

void | Promise<void>

BrokerActor.preRestart


preStart(): Promise<void>

Defined in: src/io/broker/BrokerActor.ts:235

Called after construction and before the first message is processed.

Promise<void>

BrokerActor.preStart


supervisorStrategy(): SupervisorStrategy

Defined in: src/Actor.ts:63

Supervisor strategy for this actor’s children. Defaults to restart, up to 10 times per minute, then stop.

SupervisorStrategy

BrokerActor.supervisorStrategy