public class JMSTopicTarget extends AbstractJMSTarget
Modifier and Type | Field and Description |
---|---|
private TopicConnection |
m_connection |
private TopicConnectionFactory |
m_factory |
private TopicPublisher |
m_publisher |
private TopicSession |
m_session |
private Topic |
m_topic |
Constructor and Description |
---|
JMSTopicTarget(MessageBuilder builder,
TopicConnectionFactory factory,
Topic topic) |
JMSTopicTarget(MessageBuilder builder,
TopicConnectionFactory factory,
Topic topic,
ErrorHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeConnection() |
protected Session |
getSession() |
protected void |
openConnection() |
protected void |
send(Message message) |
close, doProcessEvent, open
getErrorHandler, isOpen, processEvent, setErrorHandler
private TopicConnectionFactory m_factory
private Topic m_topic
private TopicSession m_session
private TopicPublisher m_publisher
private TopicConnection m_connection
public JMSTopicTarget(MessageBuilder builder, TopicConnectionFactory factory, Topic topic)
public JMSTopicTarget(MessageBuilder builder, TopicConnectionFactory factory, Topic topic, ErrorHandler handler)
protected void send(Message message)
send
in class AbstractJMSTarget
protected Session getSession()
getSession
in class AbstractJMSTarget
protected void openConnection()
openConnection
in class AbstractJMSTarget
protected void closeConnection()
closeConnection
in class AbstractJMSTarget