org.jboss.as.messaging

Class AbstractQueueControlHandler<T>

java.lang.Object

org.jboss.as.controller.AbstractRuntimeOnlyHandler

org.jboss.as.messaging.AbstractQueueControlHandler<T>

All Implemented Interfaces:

OperationStepHandler

Direct Known Subclasses:

JMSQueueControlHandler, QueueControlHandler

public abstract class AbstractQueueControlHandler<T>
extends AbstractRuntimeOnlyHandler

Base class for handlers that interact with either a HornetQ QueueControl or a JMSQueueControl.

Author:

Brian Stansberry (c) 2011 Red Hat Inc.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AbstractQueueControlHandler.DelegatingQueueControl<T> Exposes the method signatures that are common between QueueControl and JMSQueueControl.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHANGE_MESSAGE_PRIORITY
static String	CHANGE_MESSAGES_PRIORITY
static String	COUNT_MESSAGES
static String	EXPIRE_MESSAGE
static String	EXPIRE_MESSAGES
static String	LIST_CONSUMERS
static String	LIST_CONSUMERS_AS_JSON
static String	LIST_MESSAGE_COUNTER
static String	LIST_MESSAGE_COUNTER_AS_HTML
static String	LIST_MESSAGE_COUNTER_AS_JSON
static String	LIST_MESSAGE_COUNTER_HISTORY
static String	LIST_MESSAGE_COUNTER_HISTORY_AS_HTML
static String	LIST_MESSAGE_COUNTER_HISTORY_AS_JSON
static String	LIST_MESSAGES
static String	LIST_MESSAGES_AS_JSON
static String	MESSAGE_ID
static String	MOVE_MESSAGE
static String	MOVE_MESSAGES
static String	NEW_PRIORITY
static String	OTHER_QUEUE_NAME
static String	PAUSE
static String	REJECT_DUPLICATES
static String	REMOVE_MESSAGE
static String	REMOVE_MESSAGES
static String	RESET_MESSAGE_COUNTER
static String	RESUME
static String	SEND_MESSAGE_TO_DEAD_LETTER_ADDRESS
static String	SEND_MESSAGES_TO_DEAD_LETTER_ADDRESS

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractQueueControlHandler(ParameterValidator messageIdValidator)

Method Summary

Modifier and Type	Method and Description
protected void	executeRuntimeStep(OperationContext context, org.jboss.dmr.ModelNode operation) Execute this step in OperationContext.Stage.RUNTIME.
protected abstract AbstractQueueControlHandler.DelegatingQueueControl<T>	getQueueControl(org.hornetq.core.server.HornetQServer hqServer, String queueName)
protected abstract Object	handleAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, OperationContext context, T queueControl)
protected abstract boolean	isJMS()
void	registerOperations(ManagementResourceRegistration registry)
protected abstract void	revertAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, OperationContext context, T queueControl, Object handback)
protected void	throwUnimplementedOperationException(String operationName)

Methods inherited from class org.jboss.as.controller.AbstractRuntimeOnlyHandler

execute, resourceMustExist, waitFor

Methods inherited from class java.lang.Object

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

Field Detail

LIST_MESSAGES

public static final String LIST_MESSAGES

See Also:

Constant Field Values

LIST_MESSAGES_AS_JSON

public static final String LIST_MESSAGES_AS_JSON

See Also:

Constant Field Values

COUNT_MESSAGES

public static final String COUNT_MESSAGES

See Also:

Constant Field Values

REMOVE_MESSAGE

public static final String REMOVE_MESSAGE

See Also:

Constant Field Values

REMOVE_MESSAGES

public static final String REMOVE_MESSAGES

See Also:

Constant Field Values

EXPIRE_MESSAGES

public static final String EXPIRE_MESSAGES

See Also:

Constant Field Values

EXPIRE_MESSAGE

public static final String EXPIRE_MESSAGE

See Also:

Constant Field Values

SEND_MESSAGE_TO_DEAD_LETTER_ADDRESS

public static final String SEND_MESSAGE_TO_DEAD_LETTER_ADDRESS

See Also:

Constant Field Values

SEND_MESSAGES_TO_DEAD_LETTER_ADDRESS

public static final String SEND_MESSAGES_TO_DEAD_LETTER_ADDRESS

See Also:

Constant Field Values

CHANGE_MESSAGE_PRIORITY

public static final String CHANGE_MESSAGE_PRIORITY

See Also:

Constant Field Values

CHANGE_MESSAGES_PRIORITY

public static final String CHANGE_MESSAGES_PRIORITY

See Also:

Constant Field Values

MOVE_MESSAGE

public static final String MOVE_MESSAGE

See Also:

Constant Field Values

MOVE_MESSAGES

public static final String MOVE_MESSAGES

See Also:

Constant Field Values

LIST_MESSAGE_COUNTER

public static final String LIST_MESSAGE_COUNTER

See Also:

Constant Field Values

LIST_MESSAGE_COUNTER_AS_JSON

public static final String LIST_MESSAGE_COUNTER_AS_JSON

See Also:

Constant Field Values

LIST_MESSAGE_COUNTER_AS_HTML

public static final String LIST_MESSAGE_COUNTER_AS_HTML

See Also:

Constant Field Values

RESET_MESSAGE_COUNTER

public static final String RESET_MESSAGE_COUNTER

See Also:

Constant Field Values

LIST_MESSAGE_COUNTER_HISTORY

public static final String LIST_MESSAGE_COUNTER_HISTORY

See Also:

Constant Field Values

LIST_MESSAGE_COUNTER_HISTORY_AS_JSON

public static final String LIST_MESSAGE_COUNTER_HISTORY_AS_JSON

See Also:

Constant Field Values

LIST_MESSAGE_COUNTER_HISTORY_AS_HTML

public static final String LIST_MESSAGE_COUNTER_HISTORY_AS_HTML

See Also:

Constant Field Values

PAUSE

public static final String PAUSE

See Also:

Constant Field Values

RESUME

public static final String RESUME

See Also:

Constant Field Values

LIST_CONSUMERS

public static final String LIST_CONSUMERS

See Also:

Constant Field Values

LIST_CONSUMERS_AS_JSON

public static final String LIST_CONSUMERS_AS_JSON

See Also:

Constant Field Values

MESSAGE_ID

public static final String MESSAGE_ID

See Also:

Constant Field Values

NEW_PRIORITY

public static final String NEW_PRIORITY

See Also:

Constant Field Values

OTHER_QUEUE_NAME

public static final String OTHER_QUEUE_NAME

See Also:

Constant Field Values

REJECT_DUPLICATES

public static final String REJECT_DUPLICATES

See Also:

Constant Field Values

Constructor Detail

AbstractQueueControlHandler

protected AbstractQueueControlHandler(ParameterValidator messageIdValidator)

Method Detail

registerOperations

public void registerOperations(ManagementResourceRegistration registry)

executeRuntimeStep

protected void executeRuntimeStep(OperationContext context,
                                  org.jboss.dmr.ModelNode operation)
                           throws OperationFailedException

Description copied from class: AbstractRuntimeOnlyHandler

Execute this step in OperationContext.Stage.RUNTIME. If the operation fails, context.getFailureDescroption() must be called, or OperationFailedException must be thrown, before calling one of the context.completeStep variants. If the operation succeeded, context.getResult() should be called and the result populated with the outcome, after which one of the context.completeStep variants must be called.

Specified by:

executeRuntimeStep in class AbstractRuntimeOnlyHandler

Parameters:

context - the operation context

operation - the operation being executed

Throws:

OperationFailedException - if the operation failed before calling context.completeStep()

getQueueControl

protected abstract AbstractQueueControlHandler.DelegatingQueueControl<T> getQueueControl(org.hornetq.core.server.HornetQServer hqServer,
                                                                                         String queueName)

handleAdditionalOperation

protected abstract Object handleAdditionalOperation(String operationName,
                                                    org.jboss.dmr.ModelNode operation,
                                                    OperationContext context,
                                                    T queueControl)
                                             throws OperationFailedException

Throws:

OperationFailedException

revertAdditionalOperation

protected abstract void revertAdditionalOperation(String operationName,
                                                  org.jboss.dmr.ModelNode operation,
                                                  OperationContext context,
                                                  T queueControl,
                                                  Object handback)

isJMS

protected abstract boolean isJMS()

throwUnimplementedOperationException

protected final void throwUnimplementedOperationException(String operationName)