public class QueueControlHandler extends AbstractQueueControlHandler<org.hornetq.api.core.management.QueueControl>
QueueControl
.AbstractQueueControlHandler.DelegatingQueueControl<T>
Modifier and Type | Field and Description |
---|---|
static QueueControlHandler |
INSTANCE |
static String |
LIST_SCHEDULED_MESSAGES |
static String |
LIST_SCHEDULED_MESSAGES_AS_JSON |
CHANGE_MESSAGE_PRIORITY, CHANGE_MESSAGES_PRIORITY, COUNT_MESSAGES, EXPIRE_MESSAGE, EXPIRE_MESSAGES, LIST_CONSUMERS, LIST_CONSUMERS_AS_JSON, LIST_MESSAGE_COUNTER, LIST_MESSAGE_COUNTER_AS_HTML, LIST_MESSAGE_COUNTER_AS_JSON, LIST_MESSAGE_COUNTER_HISTORY, LIST_MESSAGE_COUNTER_HISTORY_AS_HTML, LIST_MESSAGE_COUNTER_HISTORY_AS_JSON, LIST_MESSAGES, LIST_MESSAGES_AS_JSON, MESSAGE_ID, MOVE_MESSAGE, MOVE_MESSAGES, NEW_PRIORITY, OTHER_QUEUE_NAME, PAUSE, REJECT_DUPLICATES, REMOVE_MESSAGE, REMOVE_MESSAGES, RESET_MESSAGE_COUNTER, RESUME, SEND_MESSAGE_TO_DEAD_LETTER_ADDRESS, SEND_MESSAGES_TO_DEAD_LETTER_ADDRESS
Modifier and Type | Method and Description |
---|---|
protected void |
executeRuntimeStep(OperationContext context,
org.jboss.dmr.ModelNode operation)
Execute this step in
OperationContext.Stage.RUNTIME . |
protected AbstractQueueControlHandler.DelegatingQueueControl<org.hornetq.api.core.management.QueueControl> |
getQueueControl(org.hornetq.core.server.HornetQServer hqServer,
String queueName) |
protected Object |
handleAdditionalOperation(String operationName,
org.jboss.dmr.ModelNode operation,
OperationContext context,
org.hornetq.api.core.management.QueueControl queueControl) |
boolean |
isJMS() |
void |
registerOperations(ManagementResourceRegistration registry) |
protected boolean |
resourceMustExist(OperationContext context,
org.jboss.dmr.ModelNode operation)
By default the handler will check whether the resource exist before calling @{link #executeRuntimeStep(OperationContext, ModelNode)}.
|
protected void |
revertAdditionalOperation(String operationName,
org.jboss.dmr.ModelNode operation,
OperationContext context,
org.hornetq.api.core.management.QueueControl queueControl,
Object handback) |
throwUnimplementedOperationException
execute, waitFor
public static final QueueControlHandler INSTANCE
public static final String LIST_SCHEDULED_MESSAGES
public static final String LIST_SCHEDULED_MESSAGES_AS_JSON
public void registerOperations(ManagementResourceRegistration registry)
registerOperations
in class AbstractQueueControlHandler<org.hornetq.api.core.management.QueueControl>
protected boolean resourceMustExist(OperationContext context, org.jboss.dmr.ModelNode operation)
AbstractRuntimeOnlyHandler
resourceMustExist
in class AbstractRuntimeOnlyHandler
context
- the operation contextoperation
- the operation being executedprotected 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 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.executeRuntimeStep
in class AbstractQueueControlHandler<org.hornetq.api.core.management.QueueControl>
context
- the operation contextoperation
- the operation being executedOperationFailedException
- if the operation failed before calling context.completeStep()
protected Object handleAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, OperationContext context, org.hornetq.api.core.management.QueueControl queueControl) throws OperationFailedException
handleAdditionalOperation
in class AbstractQueueControlHandler<org.hornetq.api.core.management.QueueControl>
OperationFailedException
protected void revertAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, OperationContext context, org.hornetq.api.core.management.QueueControl queueControl, Object handback)
revertAdditionalOperation
in class AbstractQueueControlHandler<org.hornetq.api.core.management.QueueControl>
public boolean isJMS()
isJMS
in class AbstractQueueControlHandler<org.hornetq.api.core.management.QueueControl>
protected AbstractQueueControlHandler.DelegatingQueueControl<org.hornetq.api.core.management.QueueControl> getQueueControl(org.hornetq.core.server.HornetQServer hqServer, String queueName)
getQueueControl
in class AbstractQueueControlHandler<org.hornetq.api.core.management.QueueControl>
Copyright © 2013 JBoss by Red Hat. All rights reserved.