beginListen method

  1. @override
void beginListen(
  1. String? correlationId,
  2. IMessageReceiver receiver
)
override

Listens for incoming messages without blocking the current thread.

  • correlationId (optional) transaction id to trace execution through call chain.
  • receiver a receiver to receive incoming messages.

See listen See IMessageReceiver

Implementation

@override
void beginListen(String? correlationId, IMessageReceiver receiver) {
  // setImmediate(() => {
  Future.delayed(Duration(milliseconds: 0), () {
    listen(correlationId, receiver);
  });
  // });
}