Package org.apache.activemq.artemis.utils

Class AutoCreateUtil

java.lang.Object

org.apache.activemq.artemis.utils.AutoCreateUtil

public class AutoCreateUtil
extends Object

Utility class to create queues 'automatically'.

Constructor Summary

Constructors

Constructor	Description
AutoCreateUtil()

Method Summary

Modifier and Type	Method	Description
static void	autoCreateQueue(ClientSession session, SimpleString destAddress, SimpleString selectorString)
static SimpleString	getCoreQueueName(ClientSession session, SimpleString destAddress)
static void	setRequiredQueueConfigurationIfNotSet(QueueConfiguration queueConfiguration, ClientSession.AddressQuery addressQuery, RoutingType routingType, SimpleString filter, boolean durable)	Set the non nullable (CreateQueueMessage_V2) queue attributes (all others have static defaults or get defaulted if null by address settings server side).

Methods inherited from class java.lang.Object

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

Constructor Details

AutoCreateUtil

public AutoCreateUtil()

Method Details

autoCreateQueue

public static void autoCreateQueue(ClientSession session,
 SimpleString destAddress,
 SimpleString selectorString)
                            throws ActiveMQException

Throws:

ActiveMQException

setRequiredQueueConfigurationIfNotSet

public static void setRequiredQueueConfigurationIfNotSet(QueueConfiguration queueConfiguration,
 ClientSession.AddressQuery addressQuery,
 RoutingType routingType,
 SimpleString filter,
 boolean durable)

Set the non nullable (CreateQueueMessage_V2) queue attributes (all others have static defaults or get defaulted if null by address settings server side).

Parameters:

queueConfiguration - the provided queue configuration the client wants to set

addressQuery - the address settings query information (this could be removed if max consumers and purge on no consumers were null-able in CreateQueueMessage_V2)

routingType - of the queue (multicast or anycast)

filter - to apply on the queue

durable - if queue is durable

getCoreQueueName

public static SimpleString getCoreQueueName(ClientSession session,
 SimpleString destAddress)