org.apache.activemq.artemis.core.server.plugin

Interface ActiveMQServerQueuePlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

All Known Implementing Classes:

LoggingActiveMQServerPlugin, NotificationActiveMQServerPlugin

public interface ActiveMQServerQueuePlugin
extends ActiveMQServerBasePlugin

Method Summary

Modifier and Type	Method and Description
default void	afterCreateQueue(Queue queue) After a queue has been created
default void	afterDestroyQueue(Queue queue, SimpleString address, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) After a queue has been destroyed
default void	beforeCreateQueue(QueueConfig queueConfig) Before a queue is created
default void	beforeCreateQueue(QueueConfiguration queueConfig) Before a queue is created
default void	beforeDestroyQueue(Queue queue, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) Before a queue is destroyed
default void	beforeDestroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress) Deprecated. use beforeDestroyQueue(Queue, SecurityAuth, boolean, boolean, boolean)

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin

init, registered, unregistered

Method Detail

beforeCreateQueue

default void beforeCreateQueue(QueueConfig queueConfig)
                        throws ActiveMQException

Before a queue is created

Parameters:

queueConfig -

Throws:

ActiveMQException

beforeCreateQueue

default void beforeCreateQueue(QueueConfiguration queueConfig)
                        throws ActiveMQException

Before a queue is created

Parameters:

queueConfig -

Throws:

ActiveMQException

afterCreateQueue

default void afterCreateQueue(Queue queue)
                       throws ActiveMQException

After a queue has been created

Parameters:

queue - The newly created queue

Throws:

ActiveMQException

beforeDestroyQueue

@Deprecated
default void beforeDestroyQueue(SimpleString queueName,
                                            SecurityAuth session,
                                            boolean checkConsumerCount,
                                            boolean removeConsumers,
                                            boolean autoDeleteAddress)
                                     throws ActiveMQException

Deprecated. use beforeDestroyQueue(Queue, SecurityAuth, boolean, boolean, boolean)

Before a queue is destroyed

Parameters:

queueName -

session -

checkConsumerCount -

removeConsumers -

autoDeleteAddress -

Throws:

ActiveMQException

beforeDestroyQueue

default void beforeDestroyQueue(Queue queue,
                                SecurityAuth session,
                                boolean checkConsumerCount,
                                boolean removeConsumers,
                                boolean autoDeleteAddress)
                         throws ActiveMQException

Before a queue is destroyed

Parameters:

queue -

session -

checkConsumerCount -

removeConsumers -

autoDeleteAddress -

Throws:

ActiveMQException

afterDestroyQueue

default void afterDestroyQueue(Queue queue,
                               SimpleString address,
                               SecurityAuth session,
                               boolean checkConsumerCount,
                               boolean removeConsumers,
                               boolean autoDeleteAddress)
                        throws ActiveMQException

After a queue has been destroyed

Parameters:

queue -

address -

session -

checkConsumerCount -

removeConsumers -

autoDeleteAddress -

Throws:

ActiveMQException