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