Overview  Package   Class  Use  Deprecated  Index
Home >> All >> com >> presumo >> jms >> [ client overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

com.presumo.jms.client
Class JmsMessageConsumer  

java.lang.Object
  com.presumo.jms.client.JmsMessageConsumer

All Implemented Interfaces:

javax.jms.MessageConsumer

Direct Known Subclasses:

JmsQueueReceiver, JmsTopicSubscriber

---

public abstract class JmsMessageConsumer

extends java.lang.Object

implements javax.jms.MessageConsumer

Implementation of the interface javax.jms.MessageConsumer. All code common to TopicSubscribers and QueueReceivers is contained within this class.

---

Field Summary
protected  boolean	closed
private  int	consumerID
protected  java.util.LinkedList	inbox
private  java.lang.Object	lock
private static com.presumo.util.log.Logger	logger
protected  javax.jms.MessageListener	messageListener
protected  JmsSession	mySession
protected  java.lang.String	selector

 

Constructor Summary
(package private)	JmsMessageConsumer(JmsSession session, java.lang.String selector)

 

Method Summary
private  void	checkSelector(java.lang.String selector)           Tests the validity of a user supplied selector.
void	close()
protected  java.lang.String	createUniqueID()           Used by QueueReceivers and DurableSubscriptions to interact with the QueueManager.
protected  java.lang.String	generateSystemFilter(java.lang.String queueName, java.lang.String id)           Used by QueueReceivers and DurableSubscriptions to interact with the QueueManager.
int	getConsumerID()
(package private) abstract  com.presumo.jms.selector.JmsOperand	getFilter()
javax.jms.MessageListener	getMessageListener()
java.lang.String	getMessageSelector()
javax.jms.Message	receive()
javax.jms.Message	receive(long timeout)
javax.jms.Message	receiveNoWait()
void	setConsumerID(int id)
void	setMessageListener(javax.jms.MessageListener listener)
(package private)  void	takeMessage(javax.jms.Message message)           Called by the session when it has a message to give to the consumer.

 

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

 

Field Detail

selector

protected java.lang.String selector

---

mySession

protected final JmsSession mySession

---

messageListener

protected javax.jms.MessageListener messageListener

---

inbox

protected java.util.LinkedList inbox

---

closed

protected volatile boolean closed

---

lock

private final java.lang.Object lock

---

consumerID

private int consumerID

---

logger

private static com.presumo.util.log.Logger logger

Constructor Detail

JmsMessageConsumer

JmsMessageConsumer(JmsSession session,
                   java.lang.String selector)
             throws javax.jms.JMSException

Method Detail

getMessageSelector

public final java.lang.String getMessageSelector()
                                          throws javax.jms.JMSException

Specified by:

getMessageSelector in interface javax.jms.MessageConsumer

---

getMessageListener

public final javax.jms.MessageListener getMessageListener()

Specified by:

getMessageListener in interface javax.jms.MessageConsumer

---

setMessageListener

public final void setMessageListener(javax.jms.MessageListener listener)
                              throws javax.jms.JMSException

Specified by:

setMessageListener in interface javax.jms.MessageConsumer

---

receive

public final javax.jms.Message receive()
                                throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

---

receive

public final javax.jms.Message receive(long timeout)
                                throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

---

receiveNoWait

public final javax.jms.Message receiveNoWait()
                                      throws javax.jms.JMSException

Specified by:

receiveNoWait in interface javax.jms.MessageConsumer

---

close

public final void close()
                 throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageConsumer

---

getConsumerID

public final int getConsumerID()

---

setConsumerID

public final void setConsumerID(int id)

---

getFilter

abstract com.presumo.jms.selector.JmsOperand getFilter()

---

takeMessage

final void takeMessage(javax.jms.Message message)

Called by the session when it has a message to give to the consumer.

---

createUniqueID

protected final java.lang.String createUniqueID()

Used by QueueReceivers and DurableSubscriptions to interact with the QueueManager.

---

generateSystemFilter

protected final java.lang.String generateSystemFilter(java.lang.String queueName,
                                                      java.lang.String id)

Used by QueueReceivers and DurableSubscriptions to interact with the QueueManager.

---

checkSelector

private void checkSelector(java.lang.String selector)
                    throws javax.jms.InvalidSelectorException

Tests the validity of a user supplied selector.

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> com >> presumo >> jms >> [ client overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---