org.jboss.mq.server
Class JMSDestination

java.lang.Object
  extended byorg.jboss.mq.server.JMSDestination
Direct Known Subclasses:
JMSQueue (src) , JMSTopic (src)

public abstract class JMSDestination
extends java.lang.Object

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


Field Summary
 BasicQueueParameters (src) parameters
          The basic queue parameters
 
Method Summary
abstract  void acknowledge(AcknowledgementRequest (src)  req, Subscription (src)  sub, Tx (src)  txId)
           
abstract  void addMessage(SpyMessage (src)  mes, Tx (src)  txId)
           
abstract  void addReceiver(Subscription (src)  sub)
           
abstract  void addSubscriber(Subscription (src)  sub)
           
abstract  void close()
           
abstract  MessageCounter (src) [] getMessageCounter()
           
 SpyDestination (src) getSpyDestination()
           
abstract  boolean isInUse()
           
abstract  void nackMessages(Subscription (src)  sub)
           
protected  long nextMessageId()
           
protected static long nextSharedMessageId()
           
abstract  SpyMessage (src) receive(Subscription (src)  sub, boolean wait)
           
abstract  void removeAllMessages()
           
abstract  void removeReceiver(Subscription (src)  sub)
           
abstract  void removeSubscriber(Subscription (src)  sub)
           
abstract  void restoreMessage(MessageReference (src)  message)
           
abstract  void restoreMessage(SpyMessage (src)  message)
           
protected  void updateNextMessageId(SpyMessage (src)  message)
           
protected static void updateSharedNextMessageId(SpyMessage (src)  message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

parameters

public BasicQueueParameters (src)  parameters
The basic queue parameters

Method Detail

getSpyDestination

public SpyDestination (src)  getSpyDestination()

addSubscriber

public abstract void addSubscriber(Subscription (src)  sub)
                            throws JMSException (src) 
Throws:
JMSException (src)

removeSubscriber

public abstract void removeSubscriber(Subscription (src)  sub)
                               throws JMSException (src) 
Throws:
JMSException (src)

nackMessages

public abstract void nackMessages(Subscription (src)  sub)
                           throws JMSException (src) 
Throws:
JMSException (src)

receive

public abstract SpyMessage (src)  receive(Subscription (src)  sub,
                                   boolean wait)
                            throws JMSException (src) 
Throws:
JMSException (src)

addReceiver

public abstract void addReceiver(Subscription (src)  sub)
                          throws JMSException (src) 
Throws:
JMSException (src)

removeReceiver

public abstract void removeReceiver(Subscription (src)  sub)

restoreMessage

public abstract void restoreMessage(MessageReference (src)  message)

restoreMessage

public abstract void restoreMessage(SpyMessage (src)  message)

isInUse

public abstract boolean isInUse()

close

public abstract void close()
                    throws JMSException (src) 
Throws:
JMSException (src)

removeAllMessages

public abstract void removeAllMessages()
                                throws JMSException (src) 
Throws:
JMSException (src)

acknowledge

public abstract void acknowledge(AcknowledgementRequest (src)  req,
                                 Subscription (src)  sub,
                                 Tx (src)  txId)
                          throws JMSException (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 abstract void addMessage(SpyMessage (src)  mes,
                                Tx (src)  txId)
                         throws JMSException (src) 
Parameters:
mes - org.jboss.mq.SpyMessage
txId - org.jboss.mq.pm.Tx
Throws:
JMSException (src) - The exception description.

getMessageCounter

public abstract MessageCounter (src) [] getMessageCounter()

nextSharedMessageId

protected static long nextSharedMessageId()

updateSharedNextMessageId

protected static void updateSharedNextMessageId(SpyMessage (src)  message)

nextMessageId

protected long nextMessageId()

updateNextMessageId

protected void updateNextMessageId(SpyMessage (src)  message)