org.axonframework.eventhandling.amqp
Class DefaultAMQPConsumerConfiguration

java.lang.Object
  extended by 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
DefaultAMQPConsumerConfiguration(String queueName)
          Initializes the configuration with the given queueName.
 
Method Summary
 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.


Copyright © 2010-2016. All Rights Reserved.