public abstract class AbstractQueueControlHandler<T>
extends org.jboss.as.controller.AbstractRuntimeOnlyHandler
QueueControl
or a JMSQueueControl
.Modifier and Type | Class and Description |
---|---|
static interface |
AbstractQueueControlHandler.DelegatingQueueControl<T>
Exposes the method signatures that are common between
org.apache.activemq.api.core.management.QueueControl
and org.apache.activemq.api.jms.management.JMSQueueControl . |
Constructor and Description |
---|
AbstractQueueControlHandler() |
Modifier and Type | Method and Description |
---|---|
protected void |
executeRuntimeStep(org.jboss.as.controller.OperationContext context,
org.jboss.dmr.ModelNode operation) |
protected abstract org.jboss.as.controller.AttributeDefinition |
getMessageIDAttributeDefinition() |
protected abstract AbstractQueueControlHandler.DelegatingQueueControl<T> |
getQueueControl(org.apache.activemq.artemis.core.server.ActiveMQServer server,
String queueName) |
protected org.jboss.as.controller.AttributeDefinition[] |
getReplyMapConsumerMessageParameterDefinition() |
protected abstract org.jboss.as.controller.AttributeDefinition[] |
getReplyMessageParameterDefinitions() |
protected abstract Object |
handleAdditionalOperation(String operationName,
org.jboss.dmr.ModelNode operation,
org.jboss.as.controller.OperationContext context,
T queueControl) |
void |
registerOperations(org.jboss.as.controller.registry.ManagementResourceRegistration registry,
org.jboss.as.controller.descriptions.ResourceDescriptionResolver resolver) |
protected abstract void |
revertAdditionalOperation(String operationName,
org.jboss.dmr.ModelNode operation,
org.jboss.as.controller.OperationContext context,
T queueControl,
Object handback) |
protected void |
throwUnimplementedOperationException(String operationName) |
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 LIST_SCHEDULED_MESSAGES
public static final String LIST_SCHEDULED_MESSAGES_AS_JSON
public static final String LIST_DELIVERING_MESSAGES
public static final String LIST_DELIVERING_MESSAGES_AS_JSON
public static final org.jboss.as.controller.operations.validation.ParameterValidator PRIORITY_VALIDATOR
protected abstract org.jboss.as.controller.AttributeDefinition getMessageIDAttributeDefinition()
protected abstract org.jboss.as.controller.AttributeDefinition[] getReplyMessageParameterDefinitions()
public void registerOperations(org.jboss.as.controller.registry.ManagementResourceRegistration registry, org.jboss.as.controller.descriptions.ResourceDescriptionResolver resolver)
protected void executeRuntimeStep(org.jboss.as.controller.OperationContext context, org.jboss.dmr.ModelNode operation) throws org.jboss.as.controller.OperationFailedException
executeRuntimeStep
in class org.jboss.as.controller.AbstractRuntimeOnlyHandler
org.jboss.as.controller.OperationFailedException
protected org.jboss.as.controller.AttributeDefinition[] getReplyMapConsumerMessageParameterDefinition()
protected abstract AbstractQueueControlHandler.DelegatingQueueControl<T> getQueueControl(org.apache.activemq.artemis.core.server.ActiveMQServer server, String queueName)
protected abstract Object handleAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, org.jboss.as.controller.OperationContext context, T queueControl) throws org.jboss.as.controller.OperationFailedException
org.jboss.as.controller.OperationFailedException
protected abstract void revertAdditionalOperation(String operationName, org.jboss.dmr.ModelNode operation, org.jboss.as.controller.OperationContext context, T queueControl, Object handback)
protected final void throwUnimplementedOperationException(String operationName)
Copyright © 2018 JBoss by Red Hat. All rights reserved.