org.axonframework.eventhandling.amqp

Class DefaultAMQPConsumerConfiguration

java.lang.Object

org.axonframework.eventhandling.amqp.DefaultAMQPConsumerConfiguration

All Implemented Interfaces:

AMQPConsumerConfiguration

public class DefaultAMQPConsumerConfiguration
extends Object
implements AMQPConsumerConfiguration

Implementation of the AMQPConsumerConfiguration that allows the Queue Name to be configured. The configuration specifies an exclusive consumer and no explicit prefetch count.

Since:

2.0

Author:

Allard Buijze

Field Summary

Fields inherited from interface org.axonframework.eventhandling.amqp.AMQPConsumerConfiguration

AMQP_CONFIG_PROPERTY

Constructor Summary

Constructors

Constructor and Description
DefaultAMQPConsumerConfiguration(String queueName) Initializes the configuration with the given queueName.

Method Summary

Methods

Modifier and Type	Method and Description
Boolean	getExclusive() Indicates whether this Cluster wishes to be an exclusive consumer on a Queue.
Integer	getPrefetchCount() Indicates how many messages this Cluster's connector may read read from the Queue before expecting messages to be acknowledged.
String	getQueueName() Returns the Queue Name the Cluster should be connected to, or null if no explicit cluster is configured.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultAMQPConsumerConfiguration

public DefaultAMQPConsumerConfiguration(String queueName)

Initializes the configuration with the given queueName.

Parameters:

queueName - The name of the Queue a cluster should connect to

Method Detail

getQueueName

public String getQueueName()

Description copied from interface: AMQPConsumerConfiguration

Returns the Queue Name the Cluster should be connected to, or null if no explicit cluster is configured.

Specified by:

getQueueName in interface AMQPConsumerConfiguration

Returns:

the Queue the cluster should be connected to, or null to revert to a default

getExclusive

public Boolean getExclusive()

Description copied from interface: AMQPConsumerConfiguration

Indicates whether this Cluster wishes to be an exclusive consumer on a Queue. null indicated that no explicit preference is provided, and a default should be used.

Specified by:

getExclusive in interface AMQPConsumerConfiguration

Returns:

the exclusivity indicator for this cluster

getPrefetchCount

public Integer getPrefetchCount()

Description copied from interface: AMQPConsumerConfiguration

Indicates how many messages this Cluster's connector may read read from the Queue before expecting messages to be acknowledged. null means no specific value is provided and a default should be used.

Specified by:

getPrefetchCount in interface AMQPConsumerConfiguration

Returns:

the number of messages a Cluster's connector may read ahead before waiting for acknowledgements.