Class ActiveMQMessageSender

java.lang.Object
org.apache.uima.adapter.jms.client.BaseMessageSender
org.apache.uima.adapter.jms.client.ActiveMQMessageSender
All Implemented Interfaces:
Runnable, MessageSender

public class ActiveMQMessageSender extends BaseMessageSender
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.