MQ-Connector

Instalation

npm install @itavy/mq-connector

API

Classes

Objects

Functions

Typedefs

RabbitMQ

Rabbit MQ interface

Kind: global class

• RabbitMQ
  • new RabbitMQ(di)
  • .close() ⇒ Promise
  • .sendMessage(message, queue, [exchange], [options]) ⇒ Promise
  • .subscribe([queue], consumer, [exchange], [topic], [options]) ⇒ Promise

new RabbitMQ(di)

| Param | Type | Description | | --- | --- | --- | | di | Object | required dependencies for RabbitMq interface |

rabbitMQ.close() ⇒ Promise

Close connection to message broker

Kind: instance method of RabbitMQ
Returns: Promise - resolves on succeeded connection
Access: public

rabbitMQ.sendMessage(message, queue, [exchange], [options]) ⇒ Promise

Send message to MQ Broker

Kind: instance method of RabbitMQ
Returns: Promise - resolves on success
Access: public

| Param | Type | Default | Description | | --- | --- | --- | --- | | message | Buffer | | message to be sent | | queue | String | | queue or topic where to send the message | | [exchange] | String | '' | exchage to be used if topics are used | | [options] | Object | {} | message options to be used when sending message |

rabbitMQ.subscribe([queue], consumer, [exchange], [topic], [options]) ⇒ Promise

Subscribe to a queue or topic

Kind: instance method of RabbitMQ
Returns: Promise - resolves on success
Access: public

| Param | Type | Default | Description | | --- | --- | --- | --- | | [queue] | String | | queue where to subscribe | | consumer | function | | function to be called when there are messages to be received | | [exchange] | String | | exchange to be used when topics are used | | [topic] | String | | topic where the queue is binded | | [options] | Object | | options for subscription |

itavy/ierror : object

Kind: global namespace

getConnector(type, options) ⇒ MqConnector

Instantiate a MQ connector

Kind: global function
Returns: MqConnector - requested mq connector

| Param | Type | Description | | --- | --- | --- | | type | Symbol | mq connector type | | options | Object | specific mq connector options |

MqConnector : Object

Kind: global typedef
Properties

| Name | Type | | --- | --- | | connect | function | | sendMessage | function | | subscribe | function |

MqConnectorTypes : Object

Kind: global typedef
Properties

| Name | Type | | --- | --- | | RABBIT_MQ | Symbol |

TODO

• Examples

LICENSE

MIT