public class JMSQueueTarget extends AbstractJMSTarget
Modifier and Type | Field and Description |
---|---|
private QueueConnection |
m_connection |
private QueueConnectionFactory |
m_factory |
private Queue |
m_queue |
private QueueSender |
m_sender |
private QueueSession |
m_session |
Constructor and Description |
---|
JMSQueueTarget(MessageBuilder builder,
QueueConnectionFactory factory,
Queue queue) |
JMSQueueTarget(MessageBuilder builder,
QueueConnectionFactory factory,
Queue queue,
ErrorHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeConnection() |
protected Session |
getSession() |
protected void |
openConnection() |
protected void |
send(Message message) |
close, doProcessEvent, open
getErrorHandler, isOpen, processEvent, setErrorHandler
private QueueConnectionFactory m_factory
private Queue m_queue
private QueueSession m_session
private QueueSender m_sender
private QueueConnection m_connection
public JMSQueueTarget(MessageBuilder builder, QueueConnectionFactory factory, Queue queue)
public JMSQueueTarget(MessageBuilder builder, QueueConnectionFactory factory, Queue queue, ErrorHandler handler)
protected void send(Message message)
send
in class AbstractJMSTarget
protected Session getSession()
getSession
in class AbstractJMSTarget
protected void openConnection()
openConnection
in class AbstractJMSTarget
protected void closeConnection()
closeConnection
in class AbstractJMSTarget