public interface TopicControl extends DestinationControl
Modifier and Type | Method and Description |
---|---|
void |
addJNDI(java.lang.String jndi)
Add the JNDI binding to this destination
|
int |
countMessagesForSubscription(java.lang.String clientID,
java.lang.String subscriptionName,
java.lang.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(java.lang.String clientID,
java.lang.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.
|
java.lang.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.
|
java.lang.Object[] |
listAllSubscriptions()
Lists all the subscriptions for this topic (both durable and non-durable).
|
java.lang.String |
listAllSubscriptionsAsJSON()
Lists all the subscriptions for this topic (both durable and non-durable) using JSON serialization.
|
java.lang.Object[] |
listDurableSubscriptions()
Lists all the durable subscriptions for this topic.
|
java.lang.String |
listDurableSubscriptionsAsJSON()
Lists all the durable subscriptions using JSON serialization.
|
java.util.Map<java.lang.String,java.lang.Object>[] |
listMessagesForSubscription(java.lang.String queueName)
Lists all the messages in this queue matching the specified queue representing the subscription.
|
java.lang.String |
listMessagesForSubscriptionAsJSON(java.lang.String queueName)
Lists all the messages in this queue matching the specified queue representing the subscription using JSON serialization.
|
java.lang.Object[] |
listNonDurableSubscriptions()
Lists all the non-durable subscriptions for this topic.
|
java.lang.String |
listNonDurableSubscriptionsAsJSON()
Lists all the non-durable subscriptions using JSON serialization.
|
void |
removeJNDI(java.lang.String jndi) |
getAddress, getDeliveringCount, getMessageCount, getMessagesAdded, getName, isTemporary, removeMessages
int getSubscriptionCount()
int getDurableSubscriptionCount()
int getNonDurableSubscriptionCount()
int getDurableMessageCount()
int getNonDurableMessageCount()
java.lang.String[] getJNDIBindings()
void addJNDI(java.lang.String jndi) throws java.lang.Exception
java.lang.Exception
void removeJNDI(java.lang.String jndi) throws java.lang.Exception
java.lang.Exception
java.lang.Object[] listAllSubscriptions() throws java.lang.Exception
java.lang.Exception
java.lang.String listAllSubscriptionsAsJSON() throws java.lang.Exception
SubscriptionInfo.from(String)
.java.lang.Exception
java.lang.Object[] listDurableSubscriptions() throws java.lang.Exception
java.lang.Exception
java.lang.String listDurableSubscriptionsAsJSON() throws java.lang.Exception
SubscriptionInfo.from(String)
.java.lang.Exception
java.lang.Object[] listNonDurableSubscriptions() throws java.lang.Exception
java.lang.Exception
java.lang.String listNonDurableSubscriptionsAsJSON() throws java.lang.Exception
SubscriptionInfo.from(String)
.java.lang.Exception
java.util.Map<java.lang.String,java.lang.Object>[] listMessagesForSubscription(java.lang.String queueName) throws java.lang.Exception
java.lang.Exception
java.lang.String listMessagesForSubscriptionAsJSON(java.lang.String queueName) throws java.lang.Exception
java.lang.Exception
int countMessagesForSubscription(java.lang.String clientID, java.lang.String subscriptionName, java.lang.String filter) throws java.lang.Exception
null
or an empty filter will count all messages from this queue.java.lang.Exception
void dropDurableSubscription(java.lang.String clientID, java.lang.String subscriptionName) throws java.lang.Exception
java.lang.Exception
void dropAllSubscriptions() throws java.lang.Exception
java.lang.Exception
Copyright © 2009 Red Hat Inc. All Rights Reserved.