Message Consumer

The Messaging Consumer is an object which can send text messages to a Queue or Topic destination in the built-in Message Broker. This version is backed by the full fledged messaging broker Apache ActiveMQ.

Overview

• Module: messaging/v4/consumer
• Alias: messaging/consumer
• Definition: https://github.com/eclipse/dirigible/issues/92
• Source: /messaging/v4/consumer.js
• Facade: MessagingFacade
• Status: stable

Basic Usage

var consumer = require("messaging/v4/consumer");
var message = consumer.queue("queue1").receive(1000);

Functions

---

Function	Description	Returns
queue()	Returns an object representing a Message Queue	Queue
topic()	Returns an object representing a Message Topic	Topic

Objects

---

Queue

Function	Description	Returns
receive(timeout)	Receives a message from this Message Queue if any or null with the given timeout in milliseconds	string

Topic

Function	Description	Returns
receive(timeout)	Receives a message from this Message Topic if any or null with the given timeout in milliseconds	string