Class CallbackMessageReceiver

Wraps message callback into IMessageReceiver

Hierarchy

CallbackMessageReceiver

Implements

IMessageReceiver

Index

Constructors

constructor

Methods

receiveMessage

Constructors

constructor

new CallbackMessageReceiver(callback: function): CallbackMessageReceiver

- Defined in queues/CallbackMessageReceiver.ts:10
Creates an instance of the CallbackMessageReceiver.

Parameters
- callback: function
  
  a callback function that shall be wrapped into IMessageReceiver
  - - (envelope: MessageEnvelope, queue: IMessageQueue, callback: function): void
    - Parameters
      - envelope: MessageEnvelope
      - queue: IMessageQueue
      - callback: function
        
        (err: any): void
        
        Parameters
        
        err: any
        
        Returns void
      Returns void
Returns CallbackMessageReceiver

Methods

receiveMessage

receiveMessage(envelope: MessageEnvelope, queue: IMessageQueue, callback: function): void

- Defined in queues/CallbackMessageReceiver.ts:34
Receives incoming message from the queue.

see

MessageEnvelope

see

IMessageQueue

Parameters
- envelope: MessageEnvelope
  
  an incoming message
- queue: IMessageQueue
  
  a queue where the message comes from
- callback: function
  
  callback function that receives error or null for success.
  - - (err: any): void
    - Parameters
      - err: any
      Returns void
Returns void

Generated using TypeDoc