org.apache.log.output.jms

Class JMSQueueTarget

Implemented Interfaces:
Closeable, ErrorAware, LogTarget

public class JMSQueueTarget
extends AbstractJMSTarget

A target that writes to a JMS Queue.
Author:
Mircea Toma

Field Summary

private QueueConnection
m_connection
private QueueConnectionFactory
m_factory
private Queue
m_queue
private QueueSender
m_sender
private QueueSession
m_session

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

JMSQueueTarget(MessageBuilder builder, QueueConnectionFactory factory, Queue queue)
JMSQueueTarget(MessageBuilder builder, QueueConnectionFactory factory, Queue queue, 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 QueueConnection m_connection

m_factory

private QueueConnectionFactory m_factory

m_queue

private Queue m_queue

m_sender

private QueueSender m_sender

m_session

private QueueSession m_session

Constructor Details

JMSQueueTarget

public JMSQueueTarget(MessageBuilder builder,
                      QueueConnectionFactory factory,
                      Queue queue)

JMSQueueTarget

public JMSQueueTarget(MessageBuilder builder,
                      QueueConnectionFactory factory,
                      Queue queue,
                      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