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.QueueConnectionJMS queue Connectionprivate javax.jms.QueueConnectionFactoryConnectionFactory to useprivate javax.jms.QueueQueue we will send messages toprivate javax.jms.QueueSenderSender for queueprivate javax.jms.QueueSessionSession associated with queue -
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 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.QueueConnectionFactory m_factoryConnectionFactory to use -
m_queue
private javax.jms.Queue m_queueQueue we will send messages to -
m_session
private javax.jms.QueueSession m_sessionSession associated with queue -
m_sender
private javax.jms.QueueSender m_senderSender for queue -
m_connection
private javax.jms.QueueConnection m_connectionJMS queue 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:
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
-