Skip to main content

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 TypeKeyDescriptionFields
Basic AuthbasicBasic authorization using a username/password combination

Password |  password

Username |  username

Actions#

Get Message#

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

InputKeyNotesExample

Host

string
/ Required
host192.168.0.1

Port

string
/ Required
port6543

Protocol

string
/ Required
protocol

Queue Name

string
/ Required
queueNamemyQueue

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

InputKeyNotesExample

Host

string
/ Required
host192.168.0.1

Message

string
/ Required
messageMessage to Queue

Port

string
/ Required
port6543

Protocol

string
/ Required
protocol

Queue Name

string
/ Required
queueNamemyQueue

Output Example Payload#

{  "data": false}

Reject Message#

Rejects one message from an AMQP QUEUE | key: rejectMessage

InputKeyNotesExample

Host

string
/ Required
host192.168.0.1

Port

string
/ Required
port6543

Protocol

string
/ Required
protocol

Queue Name

string
/ Required
queueNamemyQueue

Output Example Payload#

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