org.apache.log.output.jms

Class JMSTopicTarget

Implemented Interfaces:
Closeable, ErrorAware, LogTarget

public class JMSTopicTarget
extends AbstractJMSTarget

A target that writes to a JMS Topic.
Author:
Peter Donald

Field Summary

private TopicConnection
m_connection
private TopicConnectionFactory
m_factory
private TopicPublisher
m_publisher
private TopicSession
m_session
private Topic
m_topic

Fields inherited from class org.apache.log.output.jms.AbstractJMSTarget

m_builder

Fields inherited from class org.apache.log.output.AbstractTarget

DEFAULT_ERROR_HANDLER, m_errorHandler, m_isOpen

Constructor Summary

JMSTopicTarget(MessageBuilder builder, TopicConnectionFactory factory, Topic topic)
JMSTopicTarget(MessageBuilder builder, TopicConnectionFactory factory, Topic topic, ErrorHandler handler)

Method Summary

protected void
closeConnection()
protected Session
getSession()
protected void
openConnection()
protected void
send(Message message)

Methods inherited from class org.apache.log.output.jms.AbstractJMSTarget

close, closeConnection, doProcessEvent, getSession, open, openConnection, send

Methods inherited from class org.apache.log.output.AbstractTarget

close, doProcessEvent, getErrorHandler, isOpen, open, processEvent, setErrorHandler

Field Details

m_connection

private TopicConnection m_connection

m_factory

private TopicConnectionFactory m_factory

m_publisher

private TopicPublisher m_publisher

m_session

private TopicSession m_session

m_topic

private Topic m_topic

Constructor Details

JMSTopicTarget

public JMSTopicTarget(MessageBuilder builder,
                      TopicConnectionFactory factory,
                      Topic topic)

JMSTopicTarget

public JMSTopicTarget(MessageBuilder builder,
                      TopicConnectionFactory factory,
                      Topic topic,
                      ErrorHandler handler)

Method Details

closeConnection

protected void closeConnection()
Overrides:
closeConnection in interface AbstractJMSTarget

getSession

protected Session getSession()
Overrides:
getSession in interface AbstractJMSTarget

openConnection

protected void openConnection()
Overrides:
openConnection in interface AbstractJMSTarget

send

protected void send(Message message)
Overrides:
send in interface AbstractJMSTarget