public interface TopicControl extends DestinationControl
| Modifier and Type | Method and Description |
|---|---|
void |
addBinding(String binding)
Add the Registry 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.
|
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.
|
String[] |
getRegistryBindings()
Returns the Registry bindings associated with 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, removeMessagesint getSubscriptionCount()
int getDurableSubscriptionCount()
int getNonDurableSubscriptionCount()
int getDurableMessageCount()
int getNonDurableMessageCount()
String[] getRegistryBindings()
void addBinding(String binding) throws Exception
ExceptionObject[] listAllSubscriptions() throws Exception
ExceptionString listAllSubscriptionsAsJSON() throws Exception
SubscriptionInfo.from(String).ExceptionObject[] listDurableSubscriptions() throws Exception
ExceptionString listDurableSubscriptionsAsJSON() throws Exception
SubscriptionInfo.from(String).ExceptionObject[] listNonDurableSubscriptions() throws Exception
ExceptionString listNonDurableSubscriptionsAsJSON() throws Exception
SubscriptionInfo.from(String).ExceptionMap<String,Object>[] listMessagesForSubscription(String queueName) throws Exception
ExceptionString listMessagesForSubscriptionAsJSON(String queueName) throws Exception
Exceptionint countMessagesForSubscription(String clientID, String subscriptionName, String filter) throws Exception
null or an empty filter will count all messages from this queue.Exceptionvoid dropDurableSubscription(String clientID, String subscriptionName) throws Exception
ExceptionCopyright © 2018 The Apache Software Foundation. All rights reserved.