AmqpActor
Defined in: src/io/broker/AmqpActor.ts:63
AMQP 0.9.1 actor backed by amqplib. One connection, one channel
shared by producer + consumers. Bindings (queue↔exchange↔routingKey)
are configured up-front in settings; runtime additions go through
tell({ kind: 'subscribe', ... }) (currently out-of-scope — add when
needed).
autoAck=true (default) means the consumer acks the message when it
was delivered to the actor, not when the actor finished
processing. For at-least-once-with-processing, set autoAck=false
and have your handler tell back { kind: 'ack' / 'nack', delivery }.
Extends
Section titled “Extends”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new AmqpActor(
settings?):AmqpActor
Defined in: src/io/broker/AmqpActor.ts:70
Parameters
Section titled “Parameters”settings?
Section titled “settings?”Partial<AmqpActorSettings> = {}
Returns
Section titled “Returns”AmqpActor
Overrides
Section titled “Overrides”BrokerActor<AmqpActorSettings, AmqpCmd, AmqpPublish>.constructor
Methods
Section titled “Methods”onReceive()
Section titled “onReceive()”onReceive(
cmd):void
Defined in: src/io/broker/AmqpActor.ts:147
Main message handler. Receives each envelope dequeued from the mailbox. A thrown error (sync or async) is caught by the supervisor.
Parameters
Section titled “Parameters”Returns
Section titled “Returns”void
Overrides
Section titled “Overrides”postRestart()
Section titled “postRestart()”postRestart(
_reason):void|Promise<void>
Defined in: src/Actor.ts:55
Called on the fresh instance after a restart. Default: call preStart().
Parameters
Section titled “Parameters”_reason
Section titled “_reason”Error
Returns
Section titled “Returns”void | Promise<void>
Inherited from
Section titled “Inherited from”postStop()
Section titled “postStop()”postStop():
Promise<void>
Defined in: src/io/broker/BrokerActor.ts:241
Called after the actor has been terminated. Children are already stopped.
Returns
Section titled “Returns”Promise<void>
Inherited from
Section titled “Inherited from”preRestart()
Section titled “preRestart()”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().
Parameters
Section titled “Parameters”_reason
Section titled “_reason”Error
_message?
Section titled “_message?”Returns
Section titled “Returns”void | Promise<void>
Inherited from
Section titled “Inherited from”preStart()
Section titled “preStart()”preStart():
Promise<void>
Defined in: src/io/broker/BrokerActor.ts:235
Called after construction and before the first message is processed.
Returns
Section titled “Returns”Promise<void>
Inherited from
Section titled “Inherited from”supervisorStrategy()
Section titled “supervisorStrategy()”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.