Package org.apache.log.output.jms
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.TopicConnectionprivate javax.jms.TopicConnectionFactoryprivate javax.jms.TopicPublisherprivate javax.jms.TopicSessionprivate javax.jms.Topic -
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 org.apache.log.output.jms.AbstractJMSTarget
close, doProcessEvent, openMethods inherited from class org.apache.log.output.AbstractTarget
getErrorHandler, isOpen, processEvent, setErrorHandler
-
Field Details
-
m_factory
private javax.jms.TopicConnectionFactory m_factory -
m_topic
private javax.jms.Topic m_topic -
m_session
private javax.jms.TopicSession m_session -
m_publisher
private javax.jms.TopicPublisher m_publisher -
m_connection
private javax.jms.TopicConnection m_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
-