AMQP Component

Send and receive messages on an AMQP-based message broker

Component key: amqp

Description

The Advanced Message Queuing Protocol (AMQP) is a standard protocol for interacting with message brokers and queueing platforms. It is used by many common message broker services like Azure Event Hubs, Apache Qpid, RabbitMQ and more.

This component allows you to manage messages on an AMQP-based queue.

Authorization Methods

AMQP can use the following authorization methods, though no authorization method is required:

Auth Type	Key	Description	Fields
Basic Auth	basic	Basic authorization using a username/password combination	Password |  password Username |  username

Actions

Get Message

Receives a message from any AMQP based queue | key: getMessage

Input	Key	Notes	Example
Host string / Required	host		192.168.0.1
Port string / Required	port		6543
Protocol string / Required	protocol
Queue Name string / Required	queueName		myQueue

Output Example Payload

{  "data": {    "fields": {      "routingKey": "classic",      "deliveryTag": 1,      "redelivered": true,      "messageCount": 10    },    "content": {      "data": [        69,        120,        97,        109,        112,        108,        101,        32,        77,        101,        115,        115,        97,        103,        101,        32,        67,        111,        110,        116,        101,        110,        116      ],      "type": "Buffer"    },    "properties": {      "type": "Buffer",      "appId": "exampleId",      "userId": "exampleId",      "replyTo": "",      "priority": "High",      "clusterId": "exampleId",      "messageId": "exampleId",      "timestamp": "Thu, 05 Nov 2015 06:00:00 GMT",      "expiration": "",      "contentType": "text",      "deliveryMode": "exampleMode",      "correlationId": "exampleId",      "contentEncoding": ""    }  }}

---

Publish

Publishes one message to any AMQP Queue | key: publishMessage

Input	Key	Notes	Example
Host string / Required	host		192.168.0.1
Message string / Required	message		Message to Queue
Port string / Required	port		6543
Protocol string / Required	protocol
Queue Name string / Required	queueName		myQueue

Output Example Payload

{  "data": false}

---

Reject Message

Rejects one message from an AMQP QUEUE | key: rejectMessage

Input	Key	Notes	Example
Host string / Required	host		192.168.0.1
Port string / Required	port		6543
Protocol string / Required	protocol
Queue Name string / Required	queueName		myQueue

Output Example Payload

{  "data": {    "consumerTag": "amq.ctag-ExampleTag"  }}

---