AMQP listener

AMQP Listener

AMQP stands for Advances Messaging Queing Protocol.

The AMQP listener can be used to read from an AMQP destination. This destination can be a queue or topic in an AMQP environment. The connection factory determines which AMQP environment will be used.

This is a Message-driven consumer, which means that when a messsage arrives at the destination queue or topic, the consumer will be activated and the message will be consumed.

The ObjectToConnectMessageTransformer converts the message from the destination to a MessagePart and will write it to a new ConnectMessage.

The AMQP headers will be copied to the ConnectMessage.

 
In the table below, you will find an explanation of these properties. All attributes with a ‘*’ are mandatory. 

Attribute

Description

Name*

By default, we fill this out with the technical ‘tag’, followed by a serial number. Changing the name is optional.

Enabled

Set this value to true if you want this consumer to be enabled.

Consumer Autostart

Consumer will be started at startup of the interface.

Request Queue Names*

Names of the queues to receive from.

Reply Queue Name

Default queue to send reply to if sync=true and no header attribute amqp_replyTo.

Synchronized

Defines the consumer as request-response(true) or fire-forget(false). The default is false.

Timeout

Time-out in miliseconds. After time-out has passed response will be sent to Reply To.

MessagePart Name

Name of the MessagePart in a ConnectMessage where the content of the file is being stored.

Connection Factory

A connection factory determines which AMQP environment is used. By default we will use a connection factory incorporated as a Spring Bean with the name amqpConnectionFactory.

If a different connection factory is desired, you may enter the name of another connection factory.

This is a Spring reference.

Concurrent Consumers

Specify the number of concurrent Consumers to create. The default value is 1. Specifying a higher value for this setting will increase the standard level of scheduled concurrent Consumers at runtime: This is effectively the minimum number of concurrent Consumers which will be scheduled at any given time. This is a static setting. Raising the number of concurrent Consumers is recommended in order to scale the consumption of messages coming in from a queue. However, note that any ordering guarantees are lost once multiple Consumers are registered.

Mapped Request Headers

A comma separated list of headers to be mapped from the AMQP message to the ConnectMessage. The default are the standard AMQP properties.

Description

Description of the specific consumer. This is for documentation purposes.