public class JmsOutputChannel extends Object implements org.apache.uima.aae.OutputChannel
| Modifier and Type | Class and Description |
|---|---|
static class |
JmsOutputChannel.BrokerConnectionEntry |
protected class |
JmsOutputChannel.ConnectionTimer |
CloseAllChannels, InputChannels| Constructor and Description |
|---|
JmsOutputChannel() |
| Modifier and Type | Method and Description |
|---|---|
void |
bindWithClientEndpoint(org.apache.uima.aae.controller.Endpoint anEndpoint)
This method verifies that the destination (queue) exists.
|
void |
cancelTimers() |
org.apache.uima.aae.controller.AnalysisEngineController |
getAnalysisEngineController() |
org.apache.activemq.ActiveMQConnectionFactory |
getConnectionFactory() |
String |
getControllerInputEndpoint() |
String |
getName() |
String |
getServerURI() |
void |
initialize() |
boolean |
isStopping() |
void |
sendReply(org.apache.uima.aae.InProcessCache.CacheEntry entry,
org.apache.uima.aae.controller.Endpoint anEndpoint) |
void |
sendReply(int aCommand,
org.apache.uima.aae.controller.Endpoint anEndpoint,
String aCasReferenceId,
boolean notifyOnJmsException) |
void |
sendReply(ProcessingResourceMetaData aProcessingResourceMetadata,
org.apache.uima.aae.controller.Endpoint anEndpoint,
boolean serialize) |
void |
sendReply(Throwable t,
String aCasReferenceId,
String aParentCasReferenceId,
org.apache.uima.aae.controller.Endpoint anEndpoint,
int aCommand)
Sends JMS Reply Message to a given endpoint.
|
void |
sendRequest(int aCommand,
String aCasReferenceId,
org.apache.uima.aae.controller.Endpoint anEndpoint)
Sends request message to a delegate.
|
String |
serializeCAS(boolean isReply,
CAS aCAS,
String aCasReferenceId,
SerialFormat aSerializerKey)
Serializes CAS using indicated Serializer.
|
void |
setConnectionFactory(org.apache.activemq.ActiveMQConnectionFactory connectionFactory) |
void |
setController(org.apache.uima.aae.controller.AnalysisEngineController analysisEngineController) |
void |
setControllerInputEndpoint(String controllerInputEndpoint) |
protected void |
setFreeCasQueue(javax.jms.Destination destination) |
void |
setSecondaryInputQueue(String anEndpoint) |
void |
setServerURI(String aServerURI)
Sets the ActiveMQ Broker URI
|
void |
setServiceInputEndpoint(String anEnpoint) |
void |
stop() |
void |
stop(boolean shutdownNow) |
void |
stop(int channelsToClose,
boolean shutdownNow) |
public boolean isStopping()
isStopping in interface org.apache.uima.aae.OutputChannelpublic void setServerURI(String aServerURI)
setServerURI in interface org.apache.uima.aae.OutputChannelprotected void setFreeCasQueue(javax.jms.Destination destination)
public String getServerURI()
public String getName()
getName in interface org.apache.uima.aae.Channelpublic void setConnectionFactory(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
connectionFactory - public void setServiceInputEndpoint(String anEnpoint)
public void setSecondaryInputQueue(String anEndpoint)
public org.apache.activemq.ActiveMQConnectionFactory getConnectionFactory()
public void initialize()
throws org.apache.uima.aae.error.AsynchAEException
initialize in interface org.apache.uima.aae.OutputChannelorg.apache.uima.aae.error.AsynchAEExceptionpublic String serializeCAS(boolean isReply, CAS aCAS, String aCasReferenceId, SerialFormat aSerializerKey) throws Exception
aCAS - - CAS instance to serializeaSerializerKey - - a key identifying which serializer to useExceptionpublic void bindWithClientEndpoint(org.apache.uima.aae.controller.Endpoint anEndpoint) throws Exception
bindWithClientEndpoint in interface org.apache.uima.aae.OutputChannelExceptionpublic void sendRequest(int aCommand,
String aCasReferenceId,
org.apache.uima.aae.controller.Endpoint anEndpoint)
throws org.apache.uima.aae.error.AsynchAEException
sendRequest in interface org.apache.uima.aae.OutputChannelaCommand - - the type of request [Process|GetMeta]anEndpoint - - the destination where the delegate receives messagesorg.apache.uima.aae.error.AsynchAEExceptionpublic void sendReply(org.apache.uima.aae.InProcessCache.CacheEntry entry, org.apache.uima.aae.controller.Endpoint anEndpoint) throws org.apache.uima.aae.error.AsynchAEException
sendReply in interface org.apache.uima.aae.OutputChannelorg.apache.uima.aae.error.AsynchAEExceptionpublic void sendReply(int aCommand,
org.apache.uima.aae.controller.Endpoint anEndpoint,
String aCasReferenceId,
boolean notifyOnJmsException)
throws org.apache.uima.aae.error.AsynchAEException
sendReply in interface org.apache.uima.aae.OutputChannelorg.apache.uima.aae.error.AsynchAEExceptionpublic void sendReply(Throwable t, String aCasReferenceId, String aParentCasReferenceId, org.apache.uima.aae.controller.Endpoint anEndpoint, int aCommand) throws org.apache.uima.aae.error.AsynchAEException
sendReply in interface org.apache.uima.aae.OutputChannelt - - Throwable to include in the reply messageanEndpoint - - an endpoint to receive the reply messageaCasReferenceId - - a unique CAS reference idorg.apache.uima.aae.error.AsynchAEExceptionpublic void sendReply(ProcessingResourceMetaData aProcessingResourceMetadata, org.apache.uima.aae.controller.Endpoint anEndpoint, boolean serialize) throws org.apache.uima.aae.error.AsynchAEException
sendReply in interface org.apache.uima.aae.OutputChannelaProcessingResourceMetadata - anEndpoint - serialize - org.apache.uima.aae.error.AsynchAEExceptionpublic org.apache.uima.aae.controller.AnalysisEngineController getAnalysisEngineController()
public void setController(org.apache.uima.aae.controller.AnalysisEngineController analysisEngineController)
setController in interface org.apache.uima.aae.OutputChannelpublic String getControllerInputEndpoint()
public void setControllerInputEndpoint(String controllerInputEndpoint)
public void stop()
stop in interface org.apache.uima.aae.OutputChannelpublic void stop(boolean shutdownNow)
stop in interface org.apache.uima.aae.Channelpublic void stop(int channelsToClose,
boolean shutdownNow)
stop in interface org.apache.uima.aae.Channelpublic void cancelTimers()
cancelTimers in interface org.apache.uima.aae.OutputChannelCopyright © 2006–2018 The Apache Software Foundation. All rights reserved.