org.springframework.jms.connection
Class CachedMessageConsumer

java.lang.Object
  org.springframework.jms.connection.CachedMessageConsumer

 class CachedMessageConsumer
extends java.lang.Object

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

Since:

2.5.6

Author:

Juergen Hoeller

Field Summary

protected MessageConsumer

target

Constructor Summary

CachedMessageConsumer(MessageConsumer target)

Method Summary

void	close()
MessageListener	getMessageListener()
java.lang.String	getMessageSelector()
boolean	getNoLocal()
Queue	getQueue()
Topic	getTopic()
Message	receive()
Message	receive(long timeout)
Message	receiveNoWait()
void	setMessageListener(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 MessageConsumer target

Constructor Detail

CachedMessageConsumer

public CachedMessageConsumer(MessageConsumer target)

Method Detail

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws JMSException

Throws:

JMSException

getQueue

public Queue getQueue()
               throws JMSException

Throws:

JMSException

getTopic

public Topic getTopic()
               throws JMSException

Throws:

JMSException

getNoLocal

public boolean getNoLocal()
                   throws JMSException

Throws:

JMSException

getMessageListener

public MessageListener getMessageListener()
                                   throws JMSException

Throws:

JMSException

setMessageListener

public void setMessageListener(MessageListener messageListener)
                        throws JMSException

Throws:

JMSException

receive

public Message receive()
                throws JMSException

Throws:

JMSException

receive

public Message receive(long timeout)
                throws JMSException

Throws:

JMSException

receiveNoWait

public Message receiveNoWait()
                      throws JMSException

Throws:

JMSException

close

public void close()
           throws JMSException

Throws:

JMSException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object