Author: cwiklik
Date: Fri Oct 15 15:47:50 2010
New Revision: 1022971
URL: http://svn.apache.org/viewvc?rev=1022971&view=rev
Log:
UIMA-1902 Modified handleProcessRequestFromRemoteClient() to stop sending
ServiceInfo message to a client if the service is a CM. This message is now
sent by JmsInputChannel implementation for every request the service receives.
Modified:
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessRequestHandler_impl.java
Modified:
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessRequestHandler_impl.java
URL:
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessRequestHandler_impl.java?rev=1022971&r1=1022970&r2=1022971&view=diff
==============================================================================
---
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessRequestHandler_impl.java
(original)
+++
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessRequestHandler_impl.java
Fri Oct 15 15:47:50 2010
@@ -408,26 +408,7 @@ public class ProcessRequestHandler_impl
((AggregateAnalysisEngineController)
getController()).addMessageOrigin(casReferenceId,
aMessageContext.getEndpoint());
}
- if (getController().isCasMultiplier()) {
- // Send an ack to the client. The ack message will include a
FreeCasQueue
- // to enable the client to send messages to the service processing a
CAS.
- try {
-
getController().getOutputChannel().sendReply(AsynchAEMessage.ServiceInfo,
- aMessageContext.getEndpoint(), casReferenceId);
- } catch (Exception e) {
- if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.WARNING))
{
- if ( getController() != null ) {
- UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING,
CLASS_NAME.getName(),
- "handleProcessRequestFromRemoteClient",
UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
- "UIMAEE_service_exception_WARNING",
getController().getComponentName());
- }
- UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING,
getClass().getName(),
- "handleProcessRequestFromRemoteClient",
UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
- "UIMAEE_exception__WARNING", e);
- }
- }
- }
}
// To prevent processing multiple messages with the same CasReferenceId,
check the CAS cache
// to see if the message with a given CasReferenceId is already being
processed. It is, the
