Class JMSTopicTarget
java.lang.Object
org.apache.log.output.AbstractTarget
org.apache.log.output.jms.AbstractJMSTarget
org.apache.log.output.jms.JMSTopicTarget
- All Implemented Interfaces:
ErrorAware, LogTarget, Closeable
A target that writes to a JMS Topic.
- Author:
- Peter Donald
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate javax.jms.TopicConnectionJMS topic Connectionprivate javax.jms.TopicConnectionFactoryConnectionFactory to useprivate javax.jms.TopicPublisherPublisher for topicprivate javax.jms.TopicSessionSession associated with topicprivate javax.jms.TopicTopic we will send messages to -
Constructor Summary
ConstructorsConstructorDescriptionJMSTopicTarget(MessageBuilder builder, javax.jms.TopicConnectionFactory factory, javax.jms.Topic topic) JMSTopicTarget(MessageBuilder builder, javax.jms.TopicConnectionFactory factory, javax.jms.Topic topic, ErrorHandler handler) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprotected javax.jms.Sessionprotected voidprotected voidsend(javax.jms.Message message) Methods inherited from class AbstractJMSTarget
close, doProcessEvent, openMethods inherited from class AbstractTarget
getErrorHandler, isOpen, processEvent, setErrorHandler
-
Field Details
-
m_factory
private javax.jms.TopicConnectionFactory m_factoryConnectionFactory to use -
m_topic
private javax.jms.Topic m_topicTopic we will send messages to -
m_session
private javax.jms.TopicSession m_sessionSession associated with topic -
m_publisher
private javax.jms.TopicPublisher m_publisherPublisher for topic -
m_connection
private javax.jms.TopicConnection m_connectionJMS topic Connection
-
-
Constructor Details
-
JMSTopicTarget
public JMSTopicTarget(MessageBuilder builder, javax.jms.TopicConnectionFactory factory, javax.jms.Topic topic) -
JMSTopicTarget
public JMSTopicTarget(MessageBuilder builder, javax.jms.TopicConnectionFactory factory, javax.jms.Topic topic, ErrorHandler handler)
-
-
Method Details
-
send
protected void send(javax.jms.Message message) - Specified by:
sendin classAbstractJMSTarget
-
getSession
protected javax.jms.Session getSession()- Specified by:
getSessionin classAbstractJMSTarget
-
openConnection
protected void openConnection()- Specified by:
openConnectionin classAbstractJMSTarget
-
closeConnection
protected void closeConnection()- Specified by:
closeConnectionin classAbstractJMSTarget
-