public class QueueControlHandler extends AbstractQueueControlHandler<org.apache.activemq.artemis.api.core.management.QueueControl>
QueueControl
.AbstractQueueControlHandler.DelegatingQueueControl<T>
Modifier and Type | Field and Description |
---|---|
static QueueControlHandler |
INSTANCE |
CHANGE_MESSAGE_PRIORITY, CHANGE_MESSAGES_PRIORITY, COUNT_MESSAGES, EXPIRE_MESSAGE, EXPIRE_MESSAGES, LIST_CONSUMERS, LIST_CONSUMERS_AS_JSON, LIST_DELIVERING_MESSAGES, LIST_DELIVERING_MESSAGES_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, LIST_SCHEDULED_MESSAGES, LIST_SCHEDULED_MESSAGES_AS_JSON, MOVE_MESSAGE, MOVE_MESSAGES, PAUSE, PRIORITY_VALIDATOR, 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(org.jboss.as.controller.OperationContext context,
org.jboss.dmr.ModelNode operation) |
protected org.jboss.as.controller.AttributeDefinition |
getMessageIDAttributeDefinition() |
protected AbstractQueueControlHandler.DelegatingQueueControl<org.apache.activemq.artemis.api.core.management.QueueControl> |
getQueueControl(org.apache.activemq.artemis.core.server.ActiveMQServer server,
String queueName) |
protected org.jboss.as.controller.AttributeDefinition[] |
getReplyMessageParameterDefinitions() |
protected Object |
handleAdditionalOperation(String operationName,
org.jboss.dmr.ModelNode operation,
org.jboss.as.controller.OperationContext context,
org.apache.activemq.artemis.api.core.management.QueueControl queueControl) |
protected boolean |
resourceMustExist(org.jboss.as.controller.OperationContext context,
org.jboss.dmr.ModelNode operation) |
protected void |
revertAdditionalOperation(String operationName,
org.jboss.dmr.ModelNode operation,
org.jboss.as.controller.OperationContext context,
org.apache.activemq.artemis.api.core.management.QueueControl queueControl,
Object handback) |
getReplyMapConsumerMessageParameterDefinition, registerOperations, throwUnimplementedOperationException
public static final QueueControlHandler INSTANCE
protected org.jboss.as.controller.AttributeDefinition getMessageIDAttributeDefinition()
getMessageIDAttributeDefinition
in class AbstractQueueControlHandler<org.apache.activemq.artemis.api.core.management.QueueControl>
protected org.jboss.as.controller.AttributeDefinition[] getReplyMessageParameterDefinitions()
getReplyMessageParameterDefinitions
in class AbstractQueueControlHandler<org.apache.activemq.artemis.api.core.management.QueueControl>
protected boolean resourceMustExist(org.jboss.as.controller.OperationContext context, org.jboss.dmr.ModelNode operation)
resourceMustExist
in class org.jboss.as.controller.AbstractRuntimeOnlyHandler
protected void executeRuntimeStep(org.jboss.as.controller.OperationContext context, org.jboss.dmr.ModelNode operation) throws org.jboss.as.controller.OperationFailedException
executeRuntimeStep
in class AbstractQueueControlHandler<org.apache.activemq.artemis.api.core.management.QueueControl>
org.jboss.as.controller.OperationFailedException
protected Object handleAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, org.jboss.as.controller.OperationContext context, org.apache.activemq.artemis.api.core.management.QueueControl queueControl) throws org.jboss.as.controller.OperationFailedException
handleAdditionalOperation
in class AbstractQueueControlHandler<org.apache.activemq.artemis.api.core.management.QueueControl>
org.jboss.as.controller.OperationFailedException
protected void revertAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, org.jboss.as.controller.OperationContext context, org.apache.activemq.artemis.api.core.management.QueueControl queueControl, Object handback)
revertAdditionalOperation
in class AbstractQueueControlHandler<org.apache.activemq.artemis.api.core.management.QueueControl>
protected AbstractQueueControlHandler.DelegatingQueueControl<org.apache.activemq.artemis.api.core.management.QueueControl> getQueueControl(org.apache.activemq.artemis.core.server.ActiveMQServer server, String queueName)
getQueueControl
in class AbstractQueueControlHandler<org.apache.activemq.artemis.api.core.management.QueueControl>
Copyright © 2017 JBoss by Red Hat. All rights reserved.