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

Fields

Modifier and Type	Field and Description
protected MessageConsumer	target

Constructor Summary

Constructors

Constructor and Description
CachedMessageConsumer(MessageConsumer target)

Method Summary

Modifier and Type	Method and Description
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