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.

Field Summary

Fields inherited from class org.apache.uima.adapter.jms.client.BaseMessageSender
done, engine, exception, messageQueue, workerThreadFailed
Constructor Summary

Constructors

Constructor

Description

ActiveMQMessageSender(javax.jms.Connection aConnection, String aDestinationName, BaseUIMAAsynchronousEngineCommon_impl engine)
Method Summary

Modifier and Type

Method

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

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 Details
- ActiveMQMessageSender
  
  public ActiveMQMessageSender(javax.jms.Connection aConnection, String aDestinationName, BaseUIMAAsynchronousEngineCommon_impl engine) throws Exception
  
  Throws:
  
  Exception
Method Details
- getMessageProducer
  
  public javax.jms.MessageProducer getMessageProducer(javax.jms.Destination destination) throws Exception
  
  Specified by:
  
  getMessageProducer in interface MessageSender
  
  Overrides:
  
  getMessageProducer in class BaseMessageSender
  
  Throws:
  
  Exception
- setConnection
  
  public void setConnection(javax.jms.Connection aConnection)
  
  This is called when a new Connection is created after broker is restarted
  
  Specified by:
  
  setConnection in interface MessageSender
  
  Specified by:
  
  setConnection in class BaseMessageSender
- initializeProducer
  
  protected void initializeProducer() throws Exception
  
  Creates a jms session object used to instantiate message producer
  
  Specified by:
  
  initializeProducer in class BaseMessageSender
  
  Throws:
  
  Exception
- getDestinationEndpoint
  
  protected String getDestinationEndpoint() throws Exception
  
  Returns the full name of the destination queue
  
  Specified by:
  
  getDestinationEndpoint in class BaseMessageSender
  
  Throws:
  
  Exception
- getMessageProducer
  
  public javax.jms.MessageProducer getMessageProducer()
  
  Returns jsm MessageProducer
  
  Specified by:
  
  getMessageProducer in interface MessageSender
  
  Specified by:
  
  getMessageProducer in class BaseMessageSender
- createTextMessage
  
  public javax.jms.TextMessage createTextMessage() throws Exception
  
  Throws:
  
  Exception
- createBytesMessage
  
  public javax.jms.BytesMessage createBytesMessage() throws Exception
  
  Throws:
  
  Exception
- cleanup
  
  protected void cleanup()
  
  Cleanup any jms resources used by the worker thread
  
  Specified by:
  
  cleanup in class BaseMessageSender

Class ActiveMQMessageSender

Field Summary

Fields inherited from class org.apache.uima.adapter.jms.client.BaseMessageSender

Constructor Summary

Method Summary

Methods inherited from class org.apache.uima.adapter.jms.client.BaseMessageSender

Methods inherited from class java.lang.Object

Constructor Details

ActiveMQMessageSender

Method Details

getMessageProducer

setConnection

initializeProducer

getDestinationEndpoint

getMessageProducer

createTextMessage

createBytesMessage

cleanup