Package org.apache.log.output.jms
Class JMSQueueTarget
java.lang.Object
org.apache.log.output.AbstractTarget
org.apache.log.output.jms.AbstractJMSTarget
org.apache.log.output.jms.JMSQueueTarget
- All Implemented Interfaces:
ErrorAware
,LogTarget
,Closeable
A target that writes to a JMS Queue.
- Author:
- Mircea Toma
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate javax.jms.QueueConnection
private javax.jms.QueueConnectionFactory
private javax.jms.Queue
private javax.jms.QueueSender
private javax.jms.QueueSession
-
Constructor Summary
ConstructorsConstructorDescriptionJMSQueueTarget
(MessageBuilder builder, javax.jms.QueueConnectionFactory factory, javax.jms.Queue queue) JMSQueueTarget
(MessageBuilder builder, javax.jms.QueueConnectionFactory factory, javax.jms.Queue queue, ErrorHandler handler) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected javax.jms.Session
protected void
protected void
send
(javax.jms.Message message) Methods inherited from class org.apache.log.output.jms.AbstractJMSTarget
close, doProcessEvent, open
Methods inherited from class org.apache.log.output.AbstractTarget
getErrorHandler, isOpen, processEvent, setErrorHandler
-
Field Details
-
m_factory
private javax.jms.QueueConnectionFactory m_factory -
m_queue
private javax.jms.Queue m_queue -
m_session
private javax.jms.QueueSession m_session -
m_sender
private javax.jms.QueueSender m_sender -
m_connection
private javax.jms.QueueConnection m_connection
-
-
Constructor Details
-
JMSQueueTarget
public JMSQueueTarget(MessageBuilder builder, javax.jms.QueueConnectionFactory factory, javax.jms.Queue queue) -
JMSQueueTarget
public JMSQueueTarget(MessageBuilder builder, javax.jms.QueueConnectionFactory factory, javax.jms.Queue queue, ErrorHandler handler)
-
-
Method Details
-
send
protected void send(javax.jms.Message message) - Specified by:
send
in classAbstractJMSTarget
-
getSession
protected javax.jms.Session getSession()- Specified by:
getSession
in classAbstractJMSTarget
-
openConnection
protected void openConnection()- Specified by:
openConnection
in classAbstractJMSTarget
-
closeConnection
protected void closeConnection()- Specified by:
closeConnection
in classAbstractJMSTarget
-