public class ActiveMQMessageSender extends org.apache.uima.adapter.jms.client.BaseMessageSender
done, engine, exception, messageQueue, workerThreadFailed| Constructor and Description | 
|---|
| ActiveMQMessageSender(javax.jms.Connection aConnection,
                     String aDestinationName,
                     org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl engine) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected void | cleanup()Cleanup any jms resources used by the worker thread | 
| javax.jms.BytesMessage | createBytesMessage() | 
| javax.jms.TextMessage | createTextMessage() | 
| protected void | dispatchMessage(org.apache.uima.adapter.jms.message.PendingMessage pm,
               org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl engine,
               boolean casProcessRequest) | 
| protected String | getDestinationEndpoint()Returns the full name of the destination queue | 
| javax.jms.MessageProducer | getMessageProducer()Returns jsm MessageProducer | 
| javax.jms.MessageProducer | getMessageProducer(javax.jms.Destination destination) | 
| protected void | initializeProducer()Creates a jms session object used to instantiate message producer | 
| void | setConnection(javax.jms.Connection aConnection)This is called when a new Connection is created after broker is restarted | 
doStop, failed, getReasonForFailure, initializeMessage, runpublic ActiveMQMessageSender(javax.jms.Connection aConnection,
                             String aDestinationName,
                             org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl engine)
                      throws Exception
Exceptionpublic javax.jms.MessageProducer getMessageProducer(javax.jms.Destination destination)
                                             throws Exception
getMessageProducer in interface org.apache.uima.adapter.jms.client.MessageSendergetMessageProducer in class org.apache.uima.adapter.jms.client.BaseMessageSenderExceptionpublic void setConnection(javax.jms.Connection aConnection)
setConnection in interface org.apache.uima.adapter.jms.client.MessageSendersetConnection in class org.apache.uima.adapter.jms.client.BaseMessageSenderprotected String getDestinationEndpoint() throws Exception
getDestinationEndpoint in class org.apache.uima.adapter.jms.client.BaseMessageSenderExceptionprotected void initializeProducer()
                           throws Exception
initializeProducer in class org.apache.uima.adapter.jms.client.BaseMessageSenderExceptionpublic javax.jms.MessageProducer getMessageProducer()
getMessageProducer in interface org.apache.uima.adapter.jms.client.MessageSendergetMessageProducer in class org.apache.uima.adapter.jms.client.BaseMessageSenderpublic javax.jms.TextMessage createTextMessage()
                                        throws Exception
Exceptionpublic javax.jms.BytesMessage createBytesMessage()
                                          throws Exception
Exceptionprotected void cleanup()
cleanup in class org.apache.uima.adapter.jms.client.BaseMessageSenderprotected void dispatchMessage(org.apache.uima.adapter.jms.message.PendingMessage pm, org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl engine, boolean casProcessRequest) throws Exception
dispatchMessage in class org.apache.uima.adapter.jms.client.BaseMessageSenderExceptionCopyright © 2006–2018 The Apache Software Foundation. All rights reserved.