Package org.wildfly.extension.messaging.activemq.jms

Class JMSTopicReadAttributeHandler

java.lang.Object

org.jboss.as.controller.AbstractRuntimeOnlyHandler

org.wildfly.extension.messaging.activemq.jms.JMSTopicReadAttributeHandler

All Implemented Interfaces:

org.jboss.as.controller.OperationStepHandler

public class JMSTopicReadAttributeHandler
extends org.jboss.as.controller.AbstractRuntimeOnlyHandler

Implements the read-attribute operation for runtime attributes exposed by a ActiveMQ Topic.

Author:

Brian Stansberry (c) 2011 Red Hat Inc.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	JMSTopicReadAttributeHandler.DurabilityType

Field Summary

Fields

Modifier and Type	Field	Description
static final JMSTopicReadAttributeHandler	INSTANCE

Method Summary

Modifier and Type	Method	Description
void	executeRuntimeStep(org.jboss.as.controller.OperationContext context, ModelNode operation)
int	getDurableSubscriptionCount(AddressControl addressControl, ActiveMQBroker broker)
int	getNonDurableSubscriptionCount(AddressControl addressControl, ActiveMQBroker broker)
static List<QueueControl>	getQueues(JMSTopicReadAttributeHandler.DurabilityType durability, AddressControl addressControl, ActiveMQBroker broker)
int	getSubscriptionCount(AddressControl addressControl, ActiveMQBroker broker)

Methods inherited from class org.jboss.as.controller.AbstractRuntimeOnlyHandler

execute, requiresRuntime, resourceMustExist

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final JMSTopicReadAttributeHandler INSTANCE

Method Details

executeRuntimeStep

public void executeRuntimeStep(org.jboss.as.controller.OperationContext context,
 ModelNode operation)
                        throws org.jboss.as.controller.OperationFailedException

Specified by:

executeRuntimeStep in class org.jboss.as.controller.AbstractRuntimeOnlyHandler

Throws:

org.jboss.as.controller.OperationFailedException

getSubscriptionCount

public int getSubscriptionCount(AddressControl addressControl,
 ActiveMQBroker broker)

getDurableSubscriptionCount

public int getDurableSubscriptionCount(AddressControl addressControl,
 ActiveMQBroker broker)

getNonDurableSubscriptionCount

public int getNonDurableSubscriptionCount(AddressControl addressControl,
 ActiveMQBroker broker)

getQueues

public static List<QueueControl> getQueues(JMSTopicReadAttributeHandler.DurabilityType durability,
 AddressControl addressControl,
 ActiveMQBroker broker)