public class ActiveMQMessageSender extends BaseMessageSender
done, engine, exception, messageQueue, workerThreadFailed
Constructor and Description |
---|
ActiveMQMessageSender(javax.jms.Connection aConnection,
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 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, String aDestinationName, BaseUIMAAsynchronousEngineCommon_impl engine) throws Exception
Exception
public javax.jms.MessageProducer getMessageProducer(javax.jms.Destination destination) throws Exception
getMessageProducer
in interface MessageSender
getMessageProducer
in class BaseMessageSender
Exception
public void setConnection(javax.jms.Connection aConnection)
setConnection
in interface MessageSender
setConnection
in class BaseMessageSender
protected void initializeProducer() throws Exception
initializeProducer
in class BaseMessageSender
Exception
protected String getDestinationEndpoint() throws Exception
getDestinationEndpoint
in class BaseMessageSender
Exception
public javax.jms.MessageProducer getMessageProducer()
getMessageProducer
in interface MessageSender
getMessageProducer
in class BaseMessageSender
public javax.jms.TextMessage createTextMessage() throws Exception
Exception
public javax.jms.BytesMessage createBytesMessage() throws Exception
Exception
protected void cleanup()
cleanup
in class BaseMessageSender
Copyright © 2017. All rights reserved.