Smart Processes Management

Executor for Runnerty: AMQP

Module AMQP (Advanced Message Queuing Protocol) 0-9-1 Publisher. This is a wrapper from the amqplib

Installation:

npm i @runnerty/executor-amqp

Configuration:

Add in config.json:

Simple:

{
"id": "amqp_default",
"type": "@runnerty-executor-amqp",
"hostname": "localhost"
}

All parameters:

{
"id": "amqp_default",
"type": "@runnerty-executor-amqp",
"protocol": "amqp",
"hostname": "localhost",
"port": 5672,
"username": "guest",
"password": "guest",
"locale": "en_US",
"frameMax": 1000,
"heartbeat": 0,
"vhost": "/",
"options": {
"expiration": 10000,
"userId": "myUserId",
"CC": "myCC",
"BCC": ["bcc1,bcc2"],
"mandatory": false,
"persistent": true,
"deliveryMode": true,
"contentType": "myContentType",
"contentEncoding": "myContentEncoding",
"headers": { "header": "value" },
"priority": 9,
"correlationId": "myCorrelationId",
"replyTo": "myReplyTo",
"messageId": "myMessageId",
"timestamp": 999999999,
"type": "myType",
"appId": "myAppId"
}
}

Plan sample:

Add in plan.json:

Exange:

{
"id": "amqp_default",
"exange": "MY_EXANGE",
"exangeType": "direct",
"routingKey": "runnerty.test.#",
"message": "My message from Runnerty!",
"options": {
"persistent": true
}
}

Or direct to Queue:

{
"id": "amqp_default",
"queue": "MY_QUEUE",
"message": "My message from Runnerty!",
"options": {
"priority": 10
}
}

Connection parameters

Option	Type	Description
protocol	string	The to be used protocol: "amqp" or "amqps". Default value: 'amqp'.
hostname	string	Hostname. Default value: 'localhost'
port	string	Port. Default value: 5672
username	string	Username. Default value: 'guest'
password	string	Password. Default value: 'guest'
locale	string	Password. Default value: 'en_US'
frameMax	number	The size in bytes of the maximum frame allowed. Default value: 0x1000
heartbeat	number	The period of the connection heartbeat in seconds. Default value: 0
vhost	string	What VHost shall be used. Default value: '/'

Message options

Can be set in config as default or in the process. The value indicated in the process overwrites the one indicated in config.

Option	Type
expiration	string/number
userId	string
CC	string/string[]
BCC	string/string[]
mandatory	boolean
persistent	boolean
deliveryMode	boolean/number
contentType	string
contentEncoding	string
headers	object (key:value)
priority	number
correlationId	string
replyTo	string
messageId	string
timestamp	number
type	string
appId	string

More information in amqp-lib api reference

Output (Process values):

• PROCESS_EXEC_MSG_OUTPUT: Log operations message.
• PROCESS_EXEC_ERR_OUTPUT: Error output message.