public interface TopicControl extends DestinationControl
Modifier and Type | Method and Description |
---|---|
void |
addJNDI(String jndi)
Add the JNDI binding to this destination
|
int |
countMessagesForSubscription(String clientID,
String subscriptionName,
String filter)
Counts the number of messages in the subscription specified by the specified client ID and subscription name.
|
void |
dropAllSubscriptions()
Drops all subscriptions.
|
void |
dropDurableSubscription(String clientID,
String subscriptionName)
Drops the subscription specified by the specified client ID and subscription name.
|
int |
getDurableMessageCount()
Returns the number of messages for all durable subscribers for this topic.
|
int |
getDurableSubscriptionCount()
Returns the number of durable subscribers for this topic.
|
String[] |
getJNDIBindings()
Returns the JNDI bindings associated to this connection factory.
|
int |
getNonDurableMessageCount()
Returns the number of messages for all non-durable subscribers for this topic.
|
int |
getNonDurableSubscriptionCount()
Returns the number of non-durable subscribers for this topic.
|
int |
getSubscriptionCount()
Returns the number of (durable and non-durable) subscribers for this topic.
|
Object[] |
listAllSubscriptions()
Lists all the subscriptions for this topic (both durable and non-durable).
|
String |
listAllSubscriptionsAsJSON()
Lists all the subscriptions for this topic (both durable and non-durable) using JSON serialization.
|
Object[] |
listDurableSubscriptions()
Lists all the durable subscriptions for this topic.
|
String |
listDurableSubscriptionsAsJSON()
Lists all the durable subscriptions using JSON serialization.
|
Map<String,Object>[] |
listMessagesForSubscription(String queueName)
Lists all the messages in this queue matching the specified queue representing the subscription.
|
String |
listMessagesForSubscriptionAsJSON(String queueName)
Lists all the messages in this queue matching the specified queue representing the subscription using JSON serialization.
|
Object[] |
listNonDurableSubscriptions()
Lists all the non-durable subscriptions for this topic.
|
String |
listNonDurableSubscriptionsAsJSON()
Lists all the non-durable subscriptions using JSON serialization.
|
getAddress, getDeliveringCount, getMessageCount, getMessagesAdded, getName, isTemporary, removeMessages
int getSubscriptionCount()
int getDurableSubscriptionCount()
int getNonDurableSubscriptionCount()
int getDurableMessageCount()
int getNonDurableMessageCount()
String[] getJNDIBindings()
void addJNDI(String jndi) throws Exception
Exception
Object[] listAllSubscriptions() throws Exception
Exception
String listAllSubscriptionsAsJSON() throws Exception
SubscriptionInfo.from(String)
.Exception
Object[] listDurableSubscriptions() throws Exception
Exception
String listDurableSubscriptionsAsJSON() throws Exception
SubscriptionInfo.from(String)
.Exception
Object[] listNonDurableSubscriptions() throws Exception
Exception
String listNonDurableSubscriptionsAsJSON() throws Exception
SubscriptionInfo.from(String)
.Exception
Map<String,Object>[] listMessagesForSubscription(String queueName) throws Exception
Exception
String listMessagesForSubscriptionAsJSON(String queueName) throws Exception
Exception
int countMessagesForSubscription(String clientID, String subscriptionName, String filter) throws Exception
null
or an empty filter will count all messages from this queue.Exception
void dropDurableSubscription(String clientID, String subscriptionName) throws Exception
Exception
Copyright © 2018 JBoss by Red Hat. All rights reserved.