org.springframework.jms.connection
Class CachedMessageConsumer

java.lang.Object
  extended by org.springframework.jms.connection.CachedMessageConsumer
All Implemented Interfaces:
javax.jms.MessageConsumer, javax.jms.QueueReceiver, javax.jms.TopicSubscriber

 class CachedMessageConsumer
extends java.lang.Object
implements javax.jms.MessageConsumer, javax.jms.QueueReceiver, javax.jms.TopicSubscriber

JMS MessageConsumer decorator that adapts all calls to a shared MessageConsumer instance underneath.

Since:
2.5.6
Author:
Juergen Hoeller

Field Summary
protected  javax.jms.MessageConsumer target
           
 
Constructor Summary
CachedMessageConsumer(javax.jms.MessageConsumer target)
           
 
Method Summary
 void close()
           
 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)
           
 javax.jms.Message receiveNoWait()
           
 void setMessageListener(javax.jms.MessageListener messageListener)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

target

protected final javax.jms.MessageConsumer target
Constructor Detail

CachedMessageConsumer

public CachedMessageConsumer(javax.jms.MessageConsumer target)
Method Detail

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws javax.jms.JMSException
Specified by:
getMessageSelector in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException
Specified by:
getQueue in interface javax.jms.QueueReceiver
Throws:
javax.jms.JMSException

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException
Specified by:
getTopic in interface javax.jms.TopicSubscriber
Throws:
javax.jms.JMSException

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException
Specified by:
getNoLocal in interface javax.jms.TopicSubscriber
Throws:
javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException
Specified by:
getMessageListener in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

setMessageListener

public void setMessageListener(javax.jms.MessageListener messageListener)
                        throws javax.jms.JMSException
Specified by:
setMessageListener in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException
Specified by:
receive in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receive

public javax.jms.Message receive(long timeout)
                          throws javax.jms.JMSException
Specified by:
receive in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receiveNoWait

public javax.jms.Message receiveNoWait()
                                throws javax.jms.JMSException
Specified by:
receiveNoWait in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object