public static class JmsConnectionSession.JMSConsumerToTopicSubscriber extends Object implements javax.jms.TopicSubscriber
Constructor and Description |
---|
JMSConsumerToTopicSubscriber(javax.jms.JMSConsumer jmsConsumer,
javax.jms.Topic topic) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
javax.jms.MessageListener |
getMessageListener() |
String |
getMessageSelector() |
boolean |
getNoLocal() |
javax.jms.Topic |
getTopic() |
javax.jms.Message |
receive() |
javax.jms.Message |
receive(long timeout) |
javax.jms.Message |
receiveNoWait() |
void |
setMessageListener(javax.jms.MessageListener listener) |
public JMSConsumerToTopicSubscriber(javax.jms.JMSConsumer jmsConsumer, javax.jms.Topic topic)
public String getMessageSelector() throws javax.jms.JMSException
getMessageSelector
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 void setMessageListener(javax.jms.MessageListener listener) throws javax.jms.JMSException
setMessageListener
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 close() throws javax.jms.JMSException
close
in interface AutoCloseable
close
in interface javax.jms.MessageConsumer
javax.jms.JMSException
public javax.jms.Topic getTopic() throws javax.jms.JMSException
getTopic
in interface javax.jms.TopicSubscriber
javax.jms.JMSException
public boolean getNoLocal() throws javax.jms.JMSException
getNoLocal
in interface javax.jms.TopicSubscriber
javax.jms.JMSException
Copyright © 2021 JBoss by Red Hat. All rights reserved.