Skip to main content

AMQP Connector

AMQP Send and receive messages on an AMQP-based message broker

Connections

AMQP Connection

Authenticate requests to an amqp server

InputCommentsDefault
HostThe IP address or endpoint of the AMQP server192.168.0.1
PortThe port of the AMQP server5672
ProtocolProvide the desired protocol in which you want to interact with the queue.amqp
VhostThe "example/vhost" portion of amqps://amqp.example.com:5672/example/vhost
UsernameThis can be omitted if the AMQP server allows anonymous authentication
PasswordThis can be omitted if the AMQP server allows anonymous authentication

Actions

Acknowledge Message

Acknowledge a previously fetched message

InputCommentsDefault
Connection
MessageAn AMQP message. This must reference the results of a previous 'Get Message' step

Check AMQP Connection

Verify that an AMQP server is available, and return the server's connection information. This is helpful for debugging purposes.

InputCommentsDefault
Connection

Get Message

Receives a message from an AMQP-based queue

InputCommentsDefault
Queue NameProvide the name of the queue you would like to interact with.
Connection
Acknowledge MessageAutomatically mark the message received as "Acknowledged"true

Publish Message

Add a message to an AMQP-based queue

InputCommentsDefault
Connection
Queue NameProvide the name of the queue you would like to interact with. (Note: this input is required when Route Messages is false.)
ExchangeProvide the name of the exchange you would like to interact with. (Note: this parameter is required when Route Messages is true.)
Routing KeyProvide the routing key you would like to use. (Note: this parameter is required when Route Messages is true.)
Route MessageIf you would like to route this message, check this box.false
MessageProvide a message to push on to the queue.

Reject Message

Rejects one message from an AMQP-based queue

InputCommentsDefault
Queue NameProvide the name of the queue you would like to interact with.
Connection