You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/08/20 21:22:46 UTC
svn commit: r806312 -
/incubator/uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
Author: cwiklik
Date: Thu Aug 20 19:22:46 2009
New Revision: 806312
URL: http://svn.apache.org/viewvc?rev=806312&view=rev
Log:
UIMA-1477 Changed notifyOnTimeout() method to release cpcReplySemaphore before calling client callback listener
Modified:
incubator/uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
Modified: incubator/uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java?rev=806312&r1=806311&r2=806312&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java Thu Aug 20 19:22:46 2009
@@ -1804,9 +1804,9 @@
UIMAFramework.getLogger(CLASS_NAME).logrb(Level.FINEST, CLASS_NAME.getName(), "notifyOnTimout", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_cpc_timeout_INFO", new Object[] { anEndpoint });
}
status.addEventStatus("CpC", "Failed", new UimaASCollectionProcessCompleteTimeout());
+ // release the semaphore acquired in collectionProcessingComplete()
+ cpcReplySemaphore.release();
notifyListeners(null, status, AsynchAEMessage.CollectionProcessComplete);
- // release the semaphore acquired in collectionProcessingComplete()
- cpcReplySemaphore.release();
break;
case (ProcessTimeout):
@@ -2154,6 +2154,11 @@
}
else if (isCPCRequest())
{
+ try {
+ System.out.println("Uima AS Client Timed Out While Waiting for CPC Reply From a Service. CPC Request Sent To: "+getEndPointName());
+ } catch( Exception e) {
+
+ }
timeOutKind = CpCTimeout;
cpcReadySemaphore.release();
}