org.jboss.mq.server
Class JMSDestination
java.lang.Object
org.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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
parameters
public BasicQueueParameters (src) parameters
- The basic queue parameters
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.AcknowledgementRequestsub
- org.jboss.mq.SubscriptiontxId
- 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.SpyMessagetxId
- 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)