AMQP Operation

AMQPOperation32x32

Description

Perform operations on an AMQP broker.

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.