A component designed to talk to Advanced Message Queuing Protocol, (AMQP) APIs. AMQP is an open standard for passing business messages between applications or organizations (see amqp.org for more). AMQP component establishes an asynchronous communications with queues and topics to publish or consume records.
The consumer will register a non-exclusive non-durable queue with autodelete=true
and without any dead-letter. Name of the queue will be dynamically generated based on the USER_ID
, FLOW_ID
prefixed with eio_consumer_
. This queue will be bound to the exchange with specified bound key or multiple bound keys that are specified in one string separated by commas.
This component will automatically encrypt data that is sent to the queue when following environment variables are set and Don't encrypt payload
unchecked.
ELASTICIO_MESSAGE_CRYPTO_IV
- vector for symmetric encryption.ELASTICIO_MESSAGE_CRYPTO_PASSWORD
- password for symmetric encryption.These variables are by default available in the platform environment. Data will be encrypted using symmetric AES-256
encryption.
This component expects user to provide a AMQP URL, username and password should be embedded as part of the URL, for example amqp://foo:bar@server
. You can also use URL syntax to provide further parameters and any other options (e.g. vHost
or port).
Will consume the incoming message object that contains body
with the payload.
If the exchange doesn’t exist it will be created on start.
Run Now
after the SUSPENDED state, all stored messages in the queues will be processed, but not in the order they were received.#
or *
to wildcard. For more information check the tutorial provided at the RabbitMQ site.Will publish the messages into an exchange. This exchange will be created on start if it doesn’t exists.
application/octet-stream
.The technical notes page gives some technical details about AMQP component like changelog.
Following limitations of the component are known:
topic
exchanges by default. However, with the topic
exchanges one can emulate direct
and fanout
exchanges.Click here to learn more about the elastic.io iPaaS