public class PooledMessageConsumer extends Object implements MessageConsumer
MessageConsumer
which was created by PooledSession
.Constructor and Description |
---|
PooledMessageConsumer(PooledSession session,
MessageConsumer delegate)
Wraps the message consumer.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
MessageListener |
getMessageListener() |
String |
getMessageSelector() |
Message |
receive() |
Message |
receive(long timeout) |
Message |
receiveNoWait() |
void |
setMessageListener(MessageListener listener) |
String |
toString() |
public PooledMessageConsumer(PooledSession session, MessageConsumer delegate)
session
- the pooled sessiondelegate
- the created consumer to wrappublic void close() throws JMSException
close
in interface MessageConsumer
JMSException
public MessageListener getMessageListener() throws JMSException
getMessageListener
in interface MessageConsumer
JMSException
public String getMessageSelector() throws JMSException
getMessageSelector
in interface MessageConsumer
JMSException
public Message receive() throws JMSException
receive
in interface MessageConsumer
JMSException
public Message receive(long timeout) throws JMSException
receive
in interface MessageConsumer
JMSException
public Message receiveNoWait() throws JMSException
receiveNoWait
in interface MessageConsumer
JMSException
public void setMessageListener(MessageListener listener) throws JMSException
setMessageListener
in interface MessageConsumer
JMSException
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.