|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.uima.adapter.jms.client.BaseMessageSender
org.apache.uima.adapter.jms.client.ActiveMQMessageSender
public class ActiveMQMessageSender
Initializes JMS session and creates JMS MessageProducer to be used for sending messages to a given destination. It extends BaseMessageSender which starts the worker thread and is tasked with sending messages. The application threads share a common 'queue' with the worker thread. The application threads add messages to the pendingMessageList 'queue' and the worker thread consumes them.
Field Summary |
---|
Fields inherited from class org.apache.uima.adapter.jms.client.BaseMessageSender |
---|
done, engine, exception, messageQueue, workerThreadFailed |
Constructor Summary | |
---|---|
ActiveMQMessageSender(javax.jms.Connection aConnection,
java.lang.String aDestinationName,
BaseUIMAAsynchronousEngineCommon_impl engine)
|
Method Summary | |
---|---|
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 |
Methods inherited from class org.apache.uima.adapter.jms.client.BaseMessageSender |
---|
doStop, failed, getReasonForFailure, run |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ActiveMQMessageSender(javax.jms.Connection aConnection, java.lang.String aDestinationName, BaseUIMAAsynchronousEngineCommon_impl engine) throws java.lang.Exception
java.lang.Exception
Method Detail |
---|
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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |