Callback interface to receive incoming messages.
class MyMessageReceiver implements IMessageReceiver { public receiveMessage(envelop: MessageEnvelop, queue: IMessageQueue, callback) { console.log("Received message: " + envelop.getMessageAsString()); } } let messageQueue = new MemoryMessageQueue(); messageQueue.listen("123", new MyMessageReceiver()); messageQueue.open("123", (err) => { messageQueue.send("123", new MessageEnvelop(null, "mymessage", "ABC")); // Output in console: "ABC" });
Receives incoming message from the queue.
MessageEnvelope
IMessageQueue
an incoming message
a queue where the message comes from
callback function that receives error or null for success.
Generated using TypeDoc
Callback interface to receive incoming messages.
Example
class MyMessageReceiver implements IMessageReceiver { public receiveMessage(envelop: MessageEnvelop, queue: IMessageQueue, callback) { console.log("Received message: " + envelop.getMessageAsString()); } } let messageQueue = new MemoryMessageQueue(); messageQueue.listen("123", new MyMessageReceiver()); messageQueue.open("123", (err) => { messageQueue.send("123", new MessageEnvelop(null, "mymessage", "ABC")); // Output in console: "ABC" });