org.apache.activemq.artemis.core.server

Class QueueConfig.Builder

java.lang.Object

org.apache.activemq.artemis.core.server.QueueConfig.Builder

Enclosing class:

QueueConfig

public static final class QueueConfig.Builder
extends Object

Method Summary

Modifier and Type	Method and Description
QueueConfig.Builder	autoCreated(boolean autoCreated)
QueueConfig.Builder	autoDelete(boolean autoDelete)
QueueConfig.Builder	autoDeleteDelay(long autoDeleteDelay)
QueueConfig.Builder	autoDeleteMessageCount(long autoDeleteMessageCount)
QueueConfig	build() Returns a new QueueConfig using the parameters configured on the QueueConfig.Builder.
QueueConfig.Builder	configurationManaged(boolean configurationManaged)
QueueConfig.Builder	consumersBeforeDispatch(int consumersBeforeDispatch)
QueueConfig.Builder	delayBeforeDispatch(long delayBeforeDispatch)
QueueConfig.Builder	durable(boolean durable)
QueueConfig.Builder	exclusive(boolean exclusive)
QueueConfig.Builder	filter(Filter filter)
QueueConfig.Builder	groupBuckets(int groupBuckets)
QueueConfig.Builder	groupFirstKey(SimpleString groupFirstKey)
QueueConfig.Builder	groupRebalance(boolean groupRebalance)
QueueConfig.Builder	lastValue(boolean lastValue)
QueueConfig.Builder	lastValueKey(SimpleString lastValueKey)
QueueConfig.Builder	maxConsumers(int maxConsumers)
QueueConfig.Builder	nonDestructive(boolean nonDestructive)
QueueConfig.Builder	pagingManager(PagingManager pagingManager)
QueueConfig.Builder	purgeOnNoConsumers(boolean purgeOnNoConsumers)
QueueConfig.Builder	routingType(RoutingType routingType)
QueueConfig.Builder	temporary(boolean temporary)
QueueConfig.Builder	user(SimpleString user)

Methods inherited from class java.lang.Object

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

Method Detail

configurationManaged

public QueueConfig.Builder configurationManaged(boolean configurationManaged)

filter

public QueueConfig.Builder filter(Filter filter)

pagingManager

public QueueConfig.Builder pagingManager(PagingManager pagingManager)

user

public QueueConfig.Builder user(SimpleString user)

durable

public QueueConfig.Builder durable(boolean durable)

temporary

public QueueConfig.Builder temporary(boolean temporary)

autoCreated

public QueueConfig.Builder autoCreated(boolean autoCreated)

maxConsumers

public QueueConfig.Builder maxConsumers(int maxConsumers)

exclusive

public QueueConfig.Builder exclusive(boolean exclusive)

lastValue

public QueueConfig.Builder lastValue(boolean lastValue)

lastValueKey

public QueueConfig.Builder lastValueKey(SimpleString lastValueKey)

nonDestructive

public QueueConfig.Builder nonDestructive(boolean nonDestructive)

consumersBeforeDispatch

public QueueConfig.Builder consumersBeforeDispatch(int consumersBeforeDispatch)

delayBeforeDispatch

public QueueConfig.Builder delayBeforeDispatch(long delayBeforeDispatch)

purgeOnNoConsumers

public QueueConfig.Builder purgeOnNoConsumers(boolean purgeOnNoConsumers)

autoDelete

public QueueConfig.Builder autoDelete(boolean autoDelete)

autoDeleteDelay

public QueueConfig.Builder autoDeleteDelay(long autoDeleteDelay)

autoDeleteMessageCount

public QueueConfig.Builder autoDeleteMessageCount(long autoDeleteMessageCount)

groupRebalance

public QueueConfig.Builder groupRebalance(boolean groupRebalance)

groupBuckets

public QueueConfig.Builder groupBuckets(int groupBuckets)

groupFirstKey

public QueueConfig.Builder groupFirstKey(SimpleString groupFirstKey)

routingType

public QueueConfig.Builder routingType(RoutingType routingType)

build

public QueueConfig build()

Returns a new QueueConfig using the parameters configured on the QueueConfig.Builder.
The reference parameters aren't defensively copied from the QueueConfig.Builder to the QueueConfig.
This method creates a new PageSubscription only if pagingManager is not null and if FilterUtils.isTopicIdentification(org.apache.activemq.artemis.core.filter.Filter) returns false on filter.

Throws:

IllegalStateException - if the creation of PageSubscription fails