当前页面: 在线文档首页 > JBoss 3.2.7 messaging API Documentation 英文版文档

JMSQueue (JBoss Messaging API) - JBoss 3.2.7 messaging API Documentation 英文版文档

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

---

org.jboss.mq.server
Class JMSQueue

java.lang.Object
  org.jboss.mq.server.JMSDestination
      org.jboss.mq.server.JMSQueue

---

public class JMSQueue

extends JMSDestination

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

Version:

$Revision: 1.12.2.13 $

Author:

Norbert Lataille (Norbert.Lataille@m4x.org), Hiram Chirino (Cojonudo14@hotmail.com), David Maplesden (David.Maplesden@orion.co.nz)

---

Field Summary
BasicQueue	queue

 

Fields inherited from class org.jboss.mq.server.JMSDestination

parameters

 

Constructor Summary

JMSQueue(SpyDestination dest, ClientConsumer temporary, JMSDestinationManager server, BasicQueueParameters parameters)

 

Method Summary
void	acknowledge(AcknowledgementRequest req, Subscription sub, Tx txId)
void	addMessage(SpyMessage mes, Tx txId)
void	addReceiver(Subscription sub)
void	addSubscriber(Subscription sub)
SpyMessage[]	browse(String selector)
void	close()
MessageCounter[]	getMessageCounter()           Get message counter of internal queue
boolean	isInUse()
void	nackMessages(Subscription sub)
SpyMessage	receive(Subscription sub, boolean wait)
void	removeAllMessages()
void	removeReceiver(Subscription sub)
void	removeSubscriber(Subscription sub)
void	restoreMessage(MessageReference messageRef)
void	restoreMessage(SpyMessage message)
String	toString()

 

Methods inherited from class org.jboss.mq.server.JMSDestination

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 queue

Constructor Detail

JMSQueue

public JMSQueue(SpyDestination dest,
                ClientConsumer temporary,
                JMSDestinationManager server,
                BasicQueueParameters parameters)
         throws javax.jms.JMSException

Method Detail

addSubscriber

public void addSubscriber(Subscription sub)
                   throws javax.jms.JMSException

Specified by:

addSubscriber in class JMSDestination

Throws:

javax.jms.JMSException

---

removeSubscriber

public void removeSubscriber(Subscription sub)

Specified by:

removeSubscriber in class JMSDestination

---

nackMessages

public void nackMessages(Subscription sub)

Specified by:

nackMessages in class JMSDestination

---

addReceiver

public void addReceiver(Subscription sub)
                 throws javax.jms.JMSException

Specified by:

addReceiver in class JMSDestination

Throws:

javax.jms.JMSException

---

removeReceiver

public void removeReceiver(Subscription sub)

Specified by:

removeReceiver in class JMSDestination

---

restoreMessage

public void restoreMessage(MessageReference messageRef)

Specified by:

restoreMessage in class JMSDestination

---

restoreMessage

public void restoreMessage(SpyMessage message)

Specified by:

restoreMessage in class JMSDestination

---

browse

public SpyMessage[] browse(String selector)
                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

---

toString

public String toString()

---

acknowledge

public void acknowledge(AcknowledgementRequest req,
                        Subscription sub,
                        Tx txId)
                 throws javax.jms.JMSException

Specified by:

acknowledge in class JMSDestination

Parameters:

req - org.jboss.mq.AcknowledgementRequest

sub - org.jboss.mq.Subscription

txId - org.jboss.mq.pm.Tx

Throws:

javax.jms.JMSException - The exception description.

---

addMessage

public void addMessage(SpyMessage mes,
                       Tx txId)
                throws javax.jms.JMSException

Specified by:

addMessage in class JMSDestination

Parameters:

mes - org.jboss.mq.SpyMessage

txId - org.jboss.mq.pm.Tx

Throws:

javax.jms.JMSException - The exception description.

---

receive

public SpyMessage receive(Subscription sub,
                          boolean wait)
                   throws javax.jms.JMSException

Specified by:

receive in class JMSDestination

Throws:

javax.jms.JMSException

---

isInUse

public boolean isInUse()

Specified by:

isInUse in class JMSDestination

---

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in class JMSDestination

Throws:

javax.jms.JMSException

---

removeAllMessages

public void removeAllMessages()
                       throws javax.jms.JMSException

Specified by:

removeAllMessages in class JMSDestination

Throws:

javax.jms.JMSException

See Also:

JMSDestination#destroy()

---

getMessageCounter

public MessageCounter[] getMessageCounter()

Get message counter of internal queue

Specified by:

getMessageCounter in class JMSDestination

Returns:

MessageCounter[] internal queue message counter

---

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

---

Copyright © 2002 JBoss Group, LLC. All Rights Reserved.