BaseUIMAAsynchronousEngine_impl (Apache UIMA-AS Java SDK 2.9.0 User-Level API Documentation)

java.lang.Object
- org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
- - org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngine_impl

All Implemented Interfaces:: EventListener, javax.jms.MessageListener, UimaAsynchronousEngine, org.apache.uima.aae.controller.ControllerCallbackListener, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

public class BaseUIMAAsynchronousEngine_impl
extends org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
implements UimaAsynchronousEngine, javax.jms.MessageListener, org.apache.uima.aae.controller.ControllerCallbackListener, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

class BaseUIMAAsynchronousEngine_impl.ClientExceptionListener
- Nested classes/interfaces inherited from class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
  org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.ClientRequest, org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.ClientState, org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.SharedConnection, org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.ThreadMonitor, org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.UimaASShutdownHook, org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.UimaAsTransportListener

Nested Classes
Modifier and Type	Class and Description
`class`	`BaseUIMAAsynchronousEngine_impl.ClientExceptionListener`

Field Summary

Fields
Modifier and Type	Field and Description
`protected static Object`	`connectionMux`
`protected static Lock`	`globalLock`
`protected InitialContext`	`jndiContext`
`protected static Semaphore`	`sharedConnectionSemaphore`

Fields inherited from class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
abort, asynchManager, brokerURI, clientCache, clientSideJmxStats, collectionReader, consumer, cpcReadySemaphore, cpcReplySemaphore, cpcSemaphore, cpcTimeout, CpCTimeout, exc, getMetaSemaphore, idGenerator, initialized, listeners, metadataTimeout, MetadataTimeout, outstandingCasRequests, pendingMessageQueue, PingTimeout, processTimeout, ProcessTimeout, producerInitialized, producerSemaphore, remoteService, remoteTypeSystem, resourceMetadata, running, sendAndReceiveCAS, serialFormat, serviceDelegate, SHADOW_CAS_POOL, sharedConnections, shutdownHookThread, springContainerRegistry, state, threadMonitorMap, timerPerCAS, totalCasRequestsSentBetweenCpCs, uniqueIdentifier

Fields inherited from interface org.apache.uima.aae.client.UimaAsynchronousEngine
ApplicationContext, ApplicationName, CasPoolSize, CpcTimeout, DD2SpringXsltFilePath, Endpoint, ENDPOINT, GetMetaTimeout, password, ReplyWindow, SaxonClasspath, SERIALIZATION_STRATEGY, SerializationStrategy, ServerUri, ShadowCasPoolSize, SharedConnection, Timeout, TimerPerCAS, UimaEeDebug, userName

Constructor Summary

Constructors
Constructor and Description

BaseUIMAAsynchronousEngine_impl()

Constructors
Constructor and Description
`BaseUIMAAsynchronousEngine_impl()`

Method Summary

Methods
Modifier and Type	Method and Description
`protected void`	`cleanup()` Called at the end of collectionProcessingComplete - WAS closes receiving thread here
`protected javax.jms.BytesMessage`	`createBytesMessage()`
`protected org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.SharedConnection`	`createSharedConnection(String aBrokerURI)`
`protected javax.jms.TextMessage`	`createTextMessage()`
`String`	`deploy(String[] aDeploymentDescriptorList, Map anApplicationContext)` Deploys a single UIMA AS container and all services defined in provided deployment descriptors.
`String`	`deploy(String aDeploymentDescriptor, Map anApplicationContext)` First generates a Spring context from a given deploy descriptor and than deploys the context into a Spring Container.
`protected void`	`deployEmbeddedBroker()`
`protected String`	`deploySpringContainer(String[] springContextFiles)` Deploys provided context files ( and beans) in a new Spring container.
`protected org.apache.uima.adapter.jms.client.MessageSender`	`getDispatcher()`
`String`	`getEndPointName()` Return a name of the queue to which the JMS Producer is connected to.
`protected javax.jms.MessageProducer`	`getMessageProducer(javax.jms.Destination destination)`
`protected javax.jms.Session`	`getSession(javax.jms.Connection aConnection)`
`protected javax.jms.Session`	`getSession(String aBrokerURI)`
`void`	`initialize(Map anApplicationContext)` Initialize the uima ee client.
`protected void`	`initializeConsumer(String aBrokerURI)` Create a JMS Consumer on a temporary queue.
`protected void`	`initializeConsumer(String aBrokerURI, javax.jms.Connection connection)`
`protected void`	`initializeProducer(String aBrokerURI, String aQueueName)`
`protected void`	`initializeProducer(String aBrokerURI, String aQueueName, javax.jms.Connection aConnection)`
`protected javax.jms.MessageProducer`	`lookupProducerForEndpoint(org.apache.uima.aae.controller.Endpoint anEndpoint)`
`static void`	`main(String[] args)`
`void`	`notifyOnInitializationFailure(org.apache.uima.aae.controller.AnalysisEngineController aController, Exception e)`
`void`	`notifyOnInitializationFailure(Exception e)`
`void`	`notifyOnInitializationSuccess()`
`void`	`notifyOnInitializationSuccess(org.apache.uima.aae.controller.AnalysisEngineController aController)`
`void`	`notifyOnReconnecting(String aMessage)`
`void`	`notifyOnReconnectionSuccess()`
`void`	`notifyOnTermination(String aServiceName, String aCasReferenceId, Exception cause)`
`void`	`notifyOnTermination(String aServiceName, org.apache.uima.aae.UimaASApplicationEvent.EventTrigger cause)`
`void`	`onApplicationEvent(org.springframework.context.ApplicationEvent event)`
`protected void`	`setCASMessage(String aCasReferenceId, byte[] aSerializedCAS, javax.jms.Message msg)`
`protected void`	`setCASMessage(String aCasReferenceId, CAS aCAS, javax.jms.Message msg)` Initialize JMS Message with properties relevant to Process CAS request.
`protected void`	`setCASMessage(String aCasReferenceId, String aSerializedCAS, javax.jms.Message msg)`
`protected void`	`setCommonProperties(String aCasReferenceId, javax.jms.Message msg, SerialFormat serialFormat)`
`void`	`setCPCMessage(javax.jms.Message msg)`
`protected void`	`setMetaRequestMessage(javax.jms.Message msg)`
`void`	`setReleaseCASMessage(javax.jms.TextMessage msg, String aCasReferenceId)`
`void`	`stop()` Stops the asynchronous client.
`void`	`stopProducingCases()` Request Uima AS client to initiate sending Stop requests to a service for all outstanding CASes awaiting reply.
`void`	`stopProducingCases(String aCasReferenceId)` Request Uima AS client to initiate sending Stop request to a service for a given CAS id If the service is a Cas Multiplier, it will stop producing new CASes, will wait until all child CASes finish and finally returns the input CAS.
`void`	`undeploy()`
`void`	`undeploy(String aSpringContainerId)` Undeploys specified UIMA AS container and all services running within it.
`void`	`undeploy(String aSpringContainerId, int stop_level)` Undeploys Spring container with a given container Id.
`protected org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.SharedConnection`	`validateConnection(String aBrokerURI)`
`protected void`	`waitForServiceNotification()`

Methods inherited from class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
acquireCpcReadySemaphore, addStatusCallbackListener, cancelTimer, collectionProcessingComplete, connectionOpen, decrementOutstandingCasCounter, delayCasIfDelegateInTimedOutState, deserialize, deserialize, deserialize, deserializeCAS, deserializeCAS, deserializeCAS, deserializeCAS, deserializeCAS, deserializeCAS, doStop, getBrokerURI, getCache, getCAS, getMetaData, getPerformanceReport, getRemoteTypeSystem, getSerialFormat, handleCollectionProcessCompleteReply, handleException, handleException, handleException, handleMetadataReply, handleNonProcessException, handleProcessReply, handleServiceInfo, lookupConnection, notifyListeners, notifyListeners, notifyOnTimout, onBeforeMessageSend, onBeforeProcessCAS, onBeforeProcessMeta, onException, onMessage, onProducerInitialized, process, recoverSharedConnectionIfClosed, removeFromCache, removeStatusCallbackListener, reset, sendAndReceiveCAS, sendAndReceiveCAS, sendAndReceiveCAS, sendAndReceiveCAS, sendCAS, sendMetaRequest, serializeCAS, serializeCAS, setBrokeryURI, setCollectionReader, setRemoteTypeSystem, setSerialFormat, waitForCpcReply, waitForMetadataReply, wakeUpSendThread

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.uima.aae.client.UimaAsynchronousEngine
addStatusCallbackListener, collectionProcessingComplete, getCAS, getMetaData, getPerformanceReport, getSerialFormat, process, removeStatusCallbackListener, sendAndReceiveCAS, sendAndReceiveCAS, sendCAS, setCollectionReader

Methods inherited from interface javax.jms.MessageListener
onMessage

- Field Detail
  - sharedConnectionSemaphore
```
protected static Semaphore sharedConnectionSemaphore
```
  - connectionMux
```
protected static Object connectionMux
```
  - jndiContext
```
protected InitialContext jndiContext
```
  - globalLock
```
protected static Lock globalLock
```
- Constructor Detail
  - BaseUIMAAsynchronousEngine_impl
```
public BaseUIMAAsynchronousEngine_impl()
```
- Method Detail
  - createTextMessage
```
protected javax.jms.TextMessage createTextMessage()
                                           throws ResourceInitializationException
```
    Specified by:
    
    createTextMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    ResourceInitializationException
  - createBytesMessage
```
protected javax.jms.BytesMessage createBytesMessage()
                                             throws ResourceInitializationException
```
    Specified by:
    
    createBytesMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    ResourceInitializationException
  - cleanup
```
protected void cleanup()
                throws Exception
```
    Called at the end of collectionProcessingComplete - WAS closes receiving thread here
    
    Specified by:
    
    cleanup in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    Exception
  - getEndPointName
```
public String getEndPointName()
                       throws ResourceProcessException
```
    Return a name of the queue to which the JMS Producer is connected to.
    
    Specified by:
    
    getEndPointName in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    ResourceProcessException
  - setMetaRequestMessage
```
protected void setMetaRequestMessage(javax.jms.Message msg)
                              throws Exception
```
    Specified by:
    
    setMetaRequestMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    Exception
  - setCASMessage
```
protected void setCASMessage(String aCasReferenceId,
                 CAS aCAS,
                 javax.jms.Message msg)
                      throws ResourceProcessException
```
    Initialize JMS Message with properties relevant to Process CAS request.
    
    Specified by:
    
    setCASMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    ResourceProcessException
  - setCASMessage
```
protected void setCASMessage(String aCasReferenceId,
                 String aSerializedCAS,
                 javax.jms.Message msg)
                      throws ResourceProcessException
```
    Specified by:
    
    setCASMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    ResourceProcessException
  - setCASMessage
```
protected void setCASMessage(String aCasReferenceId,
                 byte[] aSerializedCAS,
                 javax.jms.Message msg)
                      throws ResourceProcessException
```
    Specified by:
    
    setCASMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    ResourceProcessException
  - setCommonProperties
```
protected void setCommonProperties(String aCasReferenceId,
                       javax.jms.Message msg,
                       SerialFormat serialFormat)
                            throws ResourceProcessException
```
    Throws:
    
    ResourceProcessException
  - stop
```
public void stop()
```
    Description copied from interface: UimaAsynchronousEngine
    
    Stops the asynchronous client. Cleans up resources, drops connection to UIMA AS service queue and stops listening on a response queue.
    
    Specified by:
    
    stop in interface UimaAsynchronousEngine
  - setCPCMessage
```
public void setCPCMessage(javax.jms.Message msg)
                   throws Exception
```
    Specified by:
    
    setCPCMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    Exception
  - createSharedConnection
```
protected org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.SharedConnection createSharedConnection(String aBrokerURI)
                                                                                                                    throws Exception
```
    Throws:
    
    Exception
  - validateConnection
```
protected org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl.SharedConnection validateConnection(String aBrokerURI)
                                                                                                                throws Exception
```
    Specified by:
    
    validateConnection in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    Exception
  - getSession
```
protected javax.jms.Session getSession(String aBrokerURI)
                                throws Exception
```
    Throws:
    
    Exception
  - getSession
```
protected javax.jms.Session getSession(javax.jms.Connection aConnection)
                                throws Exception
```
    Throws:
    
    Exception
  - lookupProducerForEndpoint
```
protected javax.jms.MessageProducer lookupProducerForEndpoint(org.apache.uima.aae.controller.Endpoint anEndpoint)
                                                       throws Exception
```
    Throws:
    
    Exception
  - initializeProducer
```
protected void initializeProducer(String aBrokerURI,
                      String aQueueName)
                           throws Exception
```
    Throws:
    
    Exception
  - initializeProducer
```
protected void initializeProducer(String aBrokerURI,
                      String aQueueName,
                      javax.jms.Connection aConnection)
                           throws Exception
```
    Throws:
    
    Exception
  - initializeConsumer
```
protected void initializeConsumer(String aBrokerURI)
                           throws Exception
```
    Create a JMS Consumer on a temporary queue. Service replies will be handled by this consumer.
    
    Parameters:
    aBrokerURI -
    
    Throws:
    
    Exception
  - initializeConsumer
```
protected void initializeConsumer(String aBrokerURI,
                      javax.jms.Connection connection)
                           throws Exception
```
    Specified by:
    
    initializeConsumer in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    Exception
  - initialize
```
public void initialize(Map anApplicationContext)
                throws ResourceInitializationException
```
    Initialize the uima ee client. Takes initialization parameters from the anApplicationContext map.
    
    Specified by:
    
    initialize in interface UimaAsynchronousEngine
    
    Specified by:
    
    initialize in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Parameters:
    anApplicationContext - - configuration containing UIMA EE Service Broker URI, service queue name, timeout value, reply window size, and CAS Pool size.
    
    Throws:
    
    ResourceInitializationException
  - deploy
```
public String deploy(String aDeploymentDescriptor,
            Map anApplicationContext)
              throws Exception
```
    First generates a Spring context from a given deploy descriptor and than deploys the context into a Spring Container.
    
    Specified by:
    
    deploy in interface UimaAsynchronousEngine
    
    Parameters:
    aDeploymentDescriptor - - deployment descriptor to generate Spring Context from
    anApplicationContext - - a Map containing properties required by dd2spring
    
    Returns:
    - a unique spring container id
    
    Throws:
    
    Exception - - if there was a problem deploying the container or UIMA AS services.
  - deploy
```
public String deploy(String[] aDeploymentDescriptorList,
            Map anApplicationContext)
              throws Exception
```
    Description copied from interface: UimaAsynchronousEngine
    
    Deploys a single UIMA AS container and all services defined in provided deployment descriptors. The deployment is within the same JVM. Each deployment descriptor contains an assembly of related UIMA AS services. This method is synchronous and will block until all UIMA AS services are completely deployed and initialized. If there is a problem deploying any of the UIMA AS services the container is destroyed and exception thrown.
    
    Specified by:
    
    deploy in interface UimaAsynchronousEngine
    
    Specified by:
    
    deploy in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Parameters:
    aDeploymentDescriptorList - - a list of deployment descriptors to deploy in a container.
    anApplicationContext - - initialization parameters needed to configure the client and services
    
    Returns:
    - the id of the container in which the UIMA AS services were deployed
    
    Throws:
    
    Exception - - if there was a problem deploying the container or UIMA AS services.
  - undeploy
```
public void undeploy()
              throws Exception
```
    Throws:
    
    Exception
  - undeploy
```
public void undeploy(String aSpringContainerId)
              throws Exception
```
    Description copied from interface: UimaAsynchronousEngine
    
    Undeploys specified UIMA AS container and all services running within it. Each UIMA AS container has a unique id assigned to it during the deploy phase. This method is synchronous and will block until the container (and all services contained within it) is destroyed.
    
    Specified by:
    
    undeploy in interface UimaAsynchronousEngine
    
    Parameters:
    aSpringContainerId - - an id of the container to be destroyed.
    
    Throws:
    
    Exception
  - undeploy
```
public void undeploy(String aSpringContainerId,
            int stop_level)
              throws Exception
```
    Undeploys Spring container with a given container Id. All deployed Spring containers are registered in the local registry under a unique id.
    
    Specified by:
    
    undeploy in interface UimaAsynchronousEngine
    
    Parameters:
    aSpringContainerId - - an id of the container to be destroyed.
    
    Throws:
    
    Exception
  - deploySpringContainer
```
protected String deploySpringContainer(String[] springContextFiles)
                                throws ResourceInitializationException
```
    Deploys provided context files ( and beans) in a new Spring container.
    
    Specified by:
    
    deploySpringContainer in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    ResourceInitializationException
  - waitForServiceNotification
```
protected void waitForServiceNotification()
                                   throws Exception
```
    Throws:
    
    Exception
  - deployEmbeddedBroker
```
protected void deployEmbeddedBroker()
                             throws Exception
```
    Throws:
    
    Exception
  - main
```
public static void main(String[] args)
```
  - setReleaseCASMessage
```
public void setReleaseCASMessage(javax.jms.TextMessage msg,
                        String aCasReferenceId)
                          throws Exception
```
    Overrides:
    
    setReleaseCASMessage in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    Exception
  - notifyOnInitializationFailure
```
public void notifyOnInitializationFailure(Exception e)
```
    Specified by:
    
    notifyOnInitializationFailure in interface org.apache.uima.aae.controller.ControllerCallbackListener
  - notifyOnInitializationSuccess
```
public void notifyOnInitializationSuccess()
```
    Specified by:
    
    notifyOnInitializationSuccess in interface org.apache.uima.aae.controller.ControllerCallbackListener
  - notifyOnInitializationFailure
```
public void notifyOnInitializationFailure(org.apache.uima.aae.controller.AnalysisEngineController aController,
                                 Exception e)
```
    Specified by:
    
    notifyOnInitializationFailure in interface org.apache.uima.aae.controller.ControllerCallbackListener
  - notifyOnInitializationSuccess
```
public void notifyOnInitializationSuccess(org.apache.uima.aae.controller.AnalysisEngineController aController)
```
    Specified by:
    
    notifyOnInitializationSuccess in interface org.apache.uima.aae.controller.ControllerCallbackListener
  - notifyOnTermination
```
public void notifyOnTermination(String aServiceName,
                       org.apache.uima.aae.UimaASApplicationEvent.EventTrigger cause)
```
    Specified by:
    
    notifyOnTermination in interface org.apache.uima.aae.controller.ControllerCallbackListener
  - notifyOnTermination
```
public void notifyOnTermination(String aServiceName,
                       String aCasReferenceId,
                       Exception cause)
```
  - getMessageProducer
```
protected javax.jms.MessageProducer getMessageProducer(javax.jms.Destination destination)
                                                throws Exception
```
    Overrides:
    
    getMessageProducer in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
    
    Throws:
    
    Exception
  - stopProducingCases
```
public void stopProducingCases()
```
    Request Uima AS client to initiate sending Stop requests to a service for all outstanding CASes awaiting reply.
    
    Specified by:
    
    stopProducingCases in interface UimaAsynchronousEngine
  - stopProducingCases
```
public void stopProducingCases(String aCasReferenceId)
```
    Request Uima AS client to initiate sending Stop request to a service for a given CAS id If the service is a Cas Multiplier, it will stop producing new CASes, will wait until all child CASes finish and finally returns the input CAS.
    
    Specified by:
    
    stopProducingCases in interface UimaAsynchronousEngine
  - getDispatcher
```
protected org.apache.uima.adapter.jms.client.MessageSender getDispatcher()
```
    Specified by:
    
    getDispatcher in class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl
  - notifyOnReconnecting
```
public void notifyOnReconnecting(String aMessage)
```
    Specified by:
    
    notifyOnReconnecting in interface org.apache.uima.aae.controller.ControllerCallbackListener
  - notifyOnReconnectionSuccess
```
public void notifyOnReconnectionSuccess()
```
    Specified by:
    
    notifyOnReconnectionSuccess in interface org.apache.uima.aae.controller.ControllerCallbackListener
  - onApplicationEvent
```
public void onApplicationEvent(org.springframework.context.ApplicationEvent event)
```
    Specified by:
    
    onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

Class BaseUIMAAsynchronousEngine_impl

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_impl

Field Summary

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

Fields inherited from interface org.apache.uima.aae.client.UimaAsynchronousEngine

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.uima.aae.client.UimaAsynchronousEngine

Methods inherited from interface javax.jms.MessageListener

Field Detail

sharedConnectionSemaphore

connectionMux

jndiContext

globalLock

Constructor Detail

BaseUIMAAsynchronousEngine_impl

Method Detail

createTextMessage

createBytesMessage

cleanup

getEndPointName

setMetaRequestMessage

setCASMessage

setCASMessage

setCASMessage

setCommonProperties

stop

setCPCMessage

createSharedConnection

validateConnection

getSession

getSession

lookupProducerForEndpoint

initializeProducer

initializeProducer

initializeConsumer

initializeConsumer

initialize

deploy

deploy

undeploy

undeploy

undeploy

deploySpringContainer

waitForServiceNotification

deployEmbeddedBroker

main

setReleaseCASMessage

notifyOnInitializationFailure

notifyOnInitializationSuccess

notifyOnInitializationFailure

notifyOnInitializationSuccess

notifyOnTermination

notifyOnTermination

getMessageProducer

stopProducingCases

stopProducingCases

getDispatcher

notifyOnReconnecting

notifyOnReconnectionSuccess

onApplicationEvent