public abstract class AbstractQueueControlHandler<T> extends AbstractRuntimeOnlyHandler
QueueControl
or a JMSQueueControl
.Modifier and Type | Class and Description |
---|---|
static interface |
AbstractQueueControlHandler.DelegatingQueueControl<T>
Exposes the method signatures that are common between
QueueControl
and JMSQueueControl . |
Modifier | Constructor and Description |
---|---|
protected |
AbstractQueueControlHandler(ParameterValidator messageIdValidator) |
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) |
execute, waitFor
public static final String LIST_MESSAGES
public static final String LIST_MESSAGES_AS_JSON
public static final String COUNT_MESSAGES
public static final String REMOVE_MESSAGE
public static final String REMOVE_MESSAGES
public static final String EXPIRE_MESSAGES
public static final String EXPIRE_MESSAGE
public static final String SEND_MESSAGE_TO_DEAD_LETTER_ADDRESS
public static final String SEND_MESSAGES_TO_DEAD_LETTER_ADDRESS
public static final String CHANGE_MESSAGE_PRIORITY
public static final String CHANGE_MESSAGES_PRIORITY
public static final String MOVE_MESSAGE
public static final String MOVE_MESSAGES
public static final String LIST_MESSAGE_COUNTER
public static final String LIST_MESSAGE_COUNTER_AS_JSON
public static final String LIST_MESSAGE_COUNTER_AS_HTML
public static final String RESET_MESSAGE_COUNTER
public static final String LIST_MESSAGE_COUNTER_HISTORY
public static final String LIST_MESSAGE_COUNTER_HISTORY_AS_JSON
public static final String LIST_MESSAGE_COUNTER_HISTORY_AS_HTML
public static final String PAUSE
public static final String RESUME
public static final String LIST_CONSUMERS
public static final String LIST_CONSUMERS_AS_JSON
public static final String MESSAGE_ID
public static final String NEW_PRIORITY
public static final String OTHER_QUEUE_NAME
public static final String REJECT_DUPLICATES
protected AbstractQueueControlHandler(ParameterValidator messageIdValidator)
public void registerOperations(ManagementResourceRegistration registry)
protected void executeRuntimeStep(OperationContext context, org.jboss.dmr.ModelNode operation) throws OperationFailedException
AbstractRuntimeOnlyHandler
OperationContext.Stage.RUNTIME
.
If the operation fails, context.getFailureDescroption()
must be called, or OperationFailedException
must be thrown, before calling context.completeStep()
.
If the operation succeeded, context.getResult()
should
be called and the result populated with the outcome, after which context.completeStep()
must be called.executeRuntimeStep
in class AbstractRuntimeOnlyHandler
context
- the operation contextoperation
- the operation being executedOperationFailedException
- if the operation failed before calling context.completeStep()
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) throws OperationFailedException
OperationFailedException
protected abstract void revertAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, OperationContext context, T queueControl, Object handback)
protected abstract boolean isJMS()
protected final void throwUnimplementedOperationException(String operationName)
Copyright © 2012 JBoss, a division of Red Hat, Inc.. All Rights Reserved.