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 JMSQueue

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

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

Field Summary
 BasicQueue (src) queue
           
 
Fields inherited from class org.jboss.mq.server.JMSDestination (src)
parameters
 
Constructor Summary
JMSQueue(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)  mes, Tx (src)  txId)
           
 void addReceiver(Subscription (src)  sub)
           
 void addSubscriber(Subscription (src)  sub)
           
 SpyMessage (src) [] browse(java.lang.String selector)
           
 void close()
           
 MessageCounter (src) [] getMessageCounter()
          Get message counter of internal queue
 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)
           
 java.lang.String toString()
           
 
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, wait, wait, wait
 

Field Detail

queue

public BasicQueue (src)  queue
Constructor Detail

JMSQueue

public JMSQueue(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)
Specified by:
removeSubscriber in class JMSDestination (src)

nackMessages

public void nackMessages(Subscription (src)  sub)
Specified by:
nackMessages in class JMSDestination (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)

browse

public SpyMessage (src) [] browse(java.lang.String selector)
                    throws JMSException (src)
Throws:
JMSException (src)

toString

public java.lang.String toString()

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)  mes,
                       Tx (src)  txId)
                throws JMSException (src)
Specified by:
addMessage in class JMSDestination (src)
Parameters:
mes - org.jboss.mq.SpyMessage
txId - org.jboss.mq.pm.Tx
Throws:
JMSException (src) - The exception description.

receive

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

isInUse

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

close

public void close()
           throws JMSException (src)
Specified by:
close in class JMSDestination (src)
Throws:
JMSException (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 internal queue

Specified by:
getMessageCounter in class JMSDestination (src)
Returns:
MessageCounter[] internal queue message counter
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