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

---

org.mom4j.jms
Class MessageConsumerImpl  

java.lang.Object
  org.mom4j.jms.MessageConsumerImpl

All Implemented Interfaces:

javax.jms.MessageConsumer, javax.jms.QueueReceiver, javax.jms.TopicSubscriber

---

public class MessageConsumerImpl

extends java.lang.Object

implements javax.jms.MessageConsumer, javax.jms.QueueReceiver, javax.jms.TopicSubscriber

---

Field Summary
private static long	consumerCount
private  java.lang.String	consumerId
private  DestinationImpl	destination
private  boolean	durable
private  javax.jms.MessageListener	listener
private  java.lang.String	messageSelector
private  boolean	noLocal
private  long	pollAsync
private  long	pollSync
private  SessionImpl	session
private  ReceiverWorker	worker

 

Constructor Summary
(package private)	MessageConsumerImpl(DestinationImpl dest, java.lang.String messageSelector, SessionImpl s)

 

Method Summary
void	close()
(package private)  java.lang.String	getConsumerId()
javax.jms.Destination	getDestination()
boolean	getDurable()
javax.jms.MessageListener	getMessageListener()
java.lang.String	getMessageSelector()
boolean	getNoLocal()
javax.jms.Queue	getQueue()
javax.jms.Topic	getTopic()
javax.jms.Message	receive()
javax.jms.Message	receive(long timeout)
(package private)  javax.jms.Message	receiveInternal()
javax.jms.Message	receiveNoWait()
(package private)  void	setConsumerId(java.lang.String cid)
void	setDurable(boolean dur)
void	setMessageListener(javax.jms.MessageListener listener)
void	setNoLocal(boolean noLocal)

 

Methods inherited from class java.lang.Object

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

 

Field Detail

consumerCount

private static long consumerCount

---

destination

private DestinationImpl destination

---

messageSelector

private java.lang.String messageSelector

---

session

private SessionImpl session

---

worker

private ReceiverWorker worker

---

listener

private javax.jms.MessageListener listener

---

consumerId

private java.lang.String consumerId

---

pollSync

private long pollSync

---

pollAsync

private long pollAsync

---

durable

private boolean durable

---

noLocal

private boolean noLocal

Constructor Detail

MessageConsumerImpl

MessageConsumerImpl(DestinationImpl dest,
                    java.lang.String messageSelector,
                    SessionImpl s)

Method Detail

setConsumerId

void setConsumerId(java.lang.String cid)

---

setMessageListener

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

Specified by:

setMessageListener in interface javax.jms.MessageConsumer

---

receive

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

Specified by:

receive in interface javax.jms.MessageConsumer

---

receive

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

Specified by:

receive in interface javax.jms.MessageConsumer

---

receiveNoWait

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

Specified by:

receiveNoWait in interface javax.jms.MessageConsumer

---

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageConsumer

---

setDurable

public void setDurable(boolean dur)

---

getDurable

public boolean getDurable()

---

setNoLocal

public void setNoLocal(boolean noLocal)

---

getNoLocal

public boolean getNoLocal()

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

---

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException

Specified by:

getMessageListener in interface javax.jms.MessageConsumer

---

getMessageSelector

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

Specified by:

getMessageSelector in interface javax.jms.MessageConsumer

---

getDestination

public javax.jms.Destination getDestination()
                                     throws javax.jms.JMSException

---

getConsumerId

final java.lang.String getConsumerId()

---

receiveInternal

final javax.jms.Message receiveInternal()

---

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException

Specified by:

getQueue in interface javax.jms.QueueReceiver

---

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException

Specified by:

getTopic in interface javax.jms.TopicSubscriber

---

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

---