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 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 void |
revertAdditionalOperation(String operationName,
org.jboss.dmr.ModelNode operation,
OperationContext context,
org.hornetq.api.core.management.QueueControl queueControl,
Object handback) |
executeRuntimeStep, 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 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, a division of Red Hat, Inc.. All rights reserved.