public class TopicRequestor
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private TopicPublisher |
publisher |
private TopicSession |
session |
private TopicSubscriber |
subscriber |
private TemporaryTopic |
temporaryTopic |
private Topic |
topic |
Constructor and Description |
---|
TopicRequestor(TopicSession session,
Topic topic) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
private TopicPublisher |
getPublisher() |
private TopicSession |
getSession() |
private TopicSubscriber |
getSubscriber() |
private TemporaryTopic |
getTemporaryTopic() |
private Topic |
getTopic() |
Message |
request(Message message) |
private void |
setPublisher(TopicPublisher publisher) |
private void |
setSession(TopicSession session) |
private void |
setSubscriber(TopicSubscriber subscriber) |
private void |
setTemporaryTopic(TemporaryTopic temporaryTopic) |
private void |
setTopic(Topic topic) |
private TopicSession session
private Topic topic
private TemporaryTopic temporaryTopic
private TopicPublisher publisher
private TopicSubscriber subscriber
public TopicRequestor(TopicSession session, Topic topic) throws JMSException
JMSException
public Message request(Message message) throws JMSException
JMSException
public void close() throws JMSException
JMSException
private void setPublisher(TopicPublisher publisher)
private TopicPublisher getPublisher()
private void setSession(TopicSession session)
private TopicSession getSession()
private void setSubscriber(TopicSubscriber subscriber)
private TopicSubscriber getSubscriber()
private void setTemporaryTopic(TemporaryTopic temporaryTopic)
private TemporaryTopic getTemporaryTopic()
private void setTopic(Topic topic)
private Topic getTopic()