org.apache.uima.adapter.jms.client
public class ActiveMQMessageSender extends BaseMessageSender
done, engine, exception, messageQueue, workerThreadFailed
Constructor and Description |
---|
ActiveMQMessageSender(javax.jms.Connection aConnection,
java.lang.String aDestinationName,
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 java.lang.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, run
public ActiveMQMessageSender(javax.jms.Connection aConnection, java.lang.String aDestinationName, BaseUIMAAsynchronousEngineCommon_impl engine) throws java.lang.Exception
java.lang.Exception
public javax.jms.MessageProducer getMessageProducer(javax.jms.Destination destination) throws java.lang.Exception
getMessageProducer
in interface MessageSender
getMessageProducer
in class BaseMessageSender
java.lang.Exception
public void setConnection(javax.jms.Connection aConnection)
setConnection
in interface MessageSender
setConnection
in class BaseMessageSender
protected void initializeProducer() throws java.lang.Exception
initializeProducer
in class BaseMessageSender
java.lang.Exception
protected java.lang.String getDestinationEndpoint() throws java.lang.Exception
getDestinationEndpoint
in class BaseMessageSender
java.lang.Exception
public javax.jms.MessageProducer getMessageProducer()
getMessageProducer
in interface MessageSender
getMessageProducer
in class BaseMessageSender
public javax.jms.TextMessage createTextMessage() throws java.lang.Exception
java.lang.Exception
public javax.jms.BytesMessage createBytesMessage() throws java.lang.Exception
java.lang.Exception
protected void cleanup()
cleanup
in class BaseMessageSender
Copyright © 2014. All Rights Reserved.