AMQP Operation
Parameters
| Name | Mandatory | Default | Used for operation | Description |
|---|---|---|---|---|
Amqp Exchange Durable |
No |
False |
declareExchange |
If true, the Exchange declared will be durable. |
Amqp Exchange Auto Delete |
No |
False |
declareExchange |
If true, the Exchange declared will auto delete. |
Amqp Queue Durable |
No |
False |
declareQueue |
If true, the Queue declared will be durable. |
Amqp Queue Exclusive |
No |
False |
declareQueue |
If true, the Queue declared will be exclusive. |
Amqp Queue Auto Delete |
No |
False |
declareQueue |
If true, the Queue declared will auto delete. |
Amqp Connection |
Yes |
Connection used for the operation. |
||
Amqp Addresses |
Yes |
A comma separated list of AMQP broker addresses, using the following pattern: <host>:<port> |
||
Amqp Virtual Host |
No |
Name of the AMQP Virtual Host used. |
||
Amqp Login |
No |
Login/Username of the AMQP Broker to use. |
||
Amqp Password |
No |
Encrypted password of the User. |
||
Amqp Uncrypted Password |
No |
Uncrypted password of the User. |
||
Amqp Connection Timeout |
No |
TCP connection timeout. |
||
Amqp Hand Shake Timeout |
No |
AMQP protocol handshake timeout. |
||
Amqp Acknowledge Mode |
No |
SESSION_TRANSACTED |
The acknowledge mode defines how the acknowledgement of messages is done. With a transaction in SESSION_TRANSACTED mode, or automatically with AUTO_ACKNOWLEDGE mode. |
|
Amqp Session Name |
No |
T1 |
openSession, closeSession |
Name of the session. Note that each session represents an AMQP Channel on the Broker. |
Amqp Operation |
Yes |
commit |
The operation performed on the broker. |
|
Amqp Exchange Name |
No |
declareExchange, deleteExchange, bindQueue, unbindQueue |
Name of the Exchange. |
|
Exchange Type |
No |
direct |
declareExchange |
Type of Exchange declared. Available types: direct, fanout, topic, headers. |
Amqp Routing Key |
No |
bindQueue, unbindQueue |
Routing Key used when binding a Queue to an Exchange. |
|
Amqp Queue Name |
No |
declareQueue, deleteQueue, bindQueue, unbindQueue |
Name of the Queue. |
Passwords are encrypted using the encrypt <password> command
on the Runtime engine console (engine command line tool).
|
Operations The following operations are available:
Operation |
Description |
commit |
Commit the changes of the current session. |
rollback |
Rollback the changes to the last commit. |
declareQueue |
Declare a new Queue. |
declareExchange |
Declare a new Exchange. |
bindQueue |
Bind a Queue to an Exchange. |
openSession |
Open the session specified with Amqp Session Name. |
deleteQueue |
Delete a Queue. |
deleteExchange |
Delete an Exchange. |
unbindQueue |
Delete a bind between a Queue and an Exchange. |
closeSession |
Close the session specified with Amqp Session Name. A closed session cannot be re-opened. |
closeConnection |
Close the connection specified with AmqpConnection. A closed connection cannot be re-opened. |
AMQP headers
The action offers the possibility to add AMQP headers for bindQueue and unbindQueue operations.
Particularly useful for headers Exchanges.
To add an AMQP header to a bind, add an AMQP_HEADER_<headerName> parameter to the action.
You can create as many headers as you want.
| Name | Type | Used for operation | Description |
|---|---|---|---|
AMQP_HEADER_<headerName> |
String |
bindQueue, unbindQueue |
A custom header. |