Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq.server
Class JMSTopic

java.lang.Object
  extended byorg.jboss.mq.server.JMSDestination (src) 
      extended byorg.jboss.mq.server.JMSTopic
public class JMSTopic
extends JMSDestination (src)

This class is a message queue which is stored (hashed by Destination) on the JMS provider

Field Summary
 
Fields inherited from class org.jboss.mq.server.JMSDestination (src)
parameters
 
Constructor Summary
JMSTopic(SpyDestination (src)  dest, ClientConsumer (src)  temporary, JMSDestinationManager (src)  server, BasicQueueParameters (src)  parameters)
           
 
Method Summary
 void acknowledge(AcknowledgementRequest (src)  req, Subscription (src)  sub, Tx (src)  txId)
           
 void addMessage(SpyMessage (src)  message, Tx (src)  txId)
           
 void addReceiver(Subscription (src)  sub)
           
 void addSubscriber(Subscription (src)  sub)
           
 void close()
           
 void createDurableSubscription(DurableSubscriptionID (src)  id)
           
 void destroyDurableSubscription(DurableSubscriptionID (src)  id)
           
 int getAllMessageCount()
           
 java.util.ArrayList getAllQueues()
           
 java.util.ArrayList getAllSubscriptions()
           
 int getAllSubscriptionsCount()
           
 int getDurableMessageCount()
           
 java.util.ArrayList getDurableSubscriptions()
           
 int getDurableSubscriptionsCount()
           
 MessageCounter (src) [] getMessageCounter()
          Get message counter of all topic internal queues
 int getNonDurableMessageCount()
           
 java.util.ArrayList getNonDurableSubscriptions()
           
 int getNonDurableSubscriptionsCount()
           
 java.util.ArrayList getPersistentQueues()
           
 java.util.ArrayList getTemporaryQueues()
           
 boolean isInUse()
           
 void nackMessages(Subscription (src)  sub)
           
 SpyMessage (src) receive(Subscription (src)  sub, boolean wait)
           
 void removeAllMessages()
           
 void removeReceiver(Subscription (src)  sub)
           
 void removeSubscriber(Subscription (src)  sub)
           
 void restoreMessage(MessageReference (src)  messageRef)
           
 void restoreMessage(SpyMessage (src)  message)
           
 void restoreMessage(SpyMessage (src)  message, DurableSubscriptionID (src)  id)
           
 
Methods inherited from class org.jboss.mq.server.JMSDestination (src)
getSpyDestination, nextMessageId, nextSharedMessageId, updateNextMessageId, updateSharedNextMessageId
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JMSTopic

public JMSTopic(SpyDestination (src)  dest,
                ClientConsumer (src)  temporary,
                JMSDestinationManager (src)  server,
                BasicQueueParameters (src)  parameters)
         throws JMSException (src)
Method Detail

addSubscriber

public void addSubscriber(Subscription (src)  sub)
                   throws JMSException (src)
Specified by:
addSubscriber in class JMSDestination (src)
Throws:
JMSException (src)

removeSubscriber

public void removeSubscriber(Subscription (src)  sub)
                      throws JMSException (src)
Specified by:
removeSubscriber in class JMSDestination (src)
Throws:
JMSException (src)

nackMessages

public void nackMessages(Subscription (src)  sub)
                  throws JMSException (src)
Specified by:
nackMessages in class JMSDestination (src)
Throws:
JMSException (src)

addReceiver

public void addReceiver(Subscription (src)  sub)
                 throws JMSException (src)
Specified by:
addReceiver in class JMSDestination (src)
Throws:
JMSException (src)

removeReceiver

public void removeReceiver(Subscription (src)  sub)
Specified by:
removeReceiver in class JMSDestination (src)

restoreMessage

public void restoreMessage(MessageReference (src)  messageRef)
Specified by:
restoreMessage in class JMSDestination (src)

restoreMessage

public void restoreMessage(SpyMessage (src)  message)
Specified by:
restoreMessage in class JMSDestination (src)

restoreMessage

public void restoreMessage(SpyMessage (src)  message,
                           DurableSubscriptionID (src)  id)

createDurableSubscription

public void createDurableSubscription(DurableSubscriptionID (src)  id)
                               throws JMSException (src)
Throws:
JMSException (src)

close

public void close()
           throws JMSException (src)
Specified by:
close in class JMSDestination (src)
Throws:
JMSException (src)

destroyDurableSubscription

public void destroyDurableSubscription(DurableSubscriptionID (src)  id)
                                throws JMSException (src)
Throws:
JMSException (src)

receive

public SpyMessage (src)  receive(Subscription (src)  sub,
                          boolean wait)
                   throws JMSException (src)
Specified by:
receive in class JMSDestination (src)
Throws:
JMSException (src)

acknowledge

public void acknowledge(AcknowledgementRequest (src)  req,
                        Subscription (src)  sub,
                        Tx (src)  txId)
                 throws JMSException (src)
Specified by:
acknowledge in class JMSDestination (src)
Parameters:
req - org.jboss.mq.AcknowledgementRequest
sub - org.jboss.mq.Subscription
txId - org.jboss.mq.pm.Tx
Throws:
JMSException (src) - The exception description.

addMessage

public void addMessage(SpyMessage (src)  message,
                       Tx (src)  txId)
                throws JMSException (src)
Specified by:
addMessage in class JMSDestination (src)
Parameters:
message - org.jboss.mq.SpyMessage
txId - org.jboss.mq.pm.Tx
Throws:
JMSException (src) - The exception description.

getAllMessageCount

public int getAllMessageCount()

getDurableMessageCount

public int getDurableMessageCount()

getNonDurableMessageCount

public int getNonDurableMessageCount()

getAllQueues

public java.util.ArrayList getAllQueues()

getTemporaryQueues

public java.util.ArrayList getTemporaryQueues()

getPersistentQueues

public java.util.ArrayList getPersistentQueues()

getAllSubscriptionsCount

public int getAllSubscriptionsCount()

getDurableSubscriptionsCount

public int getDurableSubscriptionsCount()

getNonDurableSubscriptionsCount

public int getNonDurableSubscriptionsCount()

getAllSubscriptions

public java.util.ArrayList getAllSubscriptions()

getDurableSubscriptions

public java.util.ArrayList getDurableSubscriptions()

getNonDurableSubscriptions

public java.util.ArrayList getNonDurableSubscriptions()

isInUse

public boolean isInUse()
Specified by:
isInUse in class JMSDestination (src)

removeAllMessages

public void removeAllMessages()
                       throws JMSException (src)
Specified by:
removeAllMessages in class JMSDestination (src)
Throws:
JMSException (src)
See Also:
JMSDestination#destroy()

getMessageCounter

public MessageCounter (src) [] getMessageCounter()
Get message counter of all topic internal queues

Specified by:
getMessageCounter in class JMSDestination (src)
Returns:
MessageCounter[] topic queue message counter array
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD