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/11 17:24:59 UTC
svn commit: r803154 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
Author: cwiklik
Date: Tue Aug 11 15:24:58 2009
New Revision: 803154
URL: http://svn.apache.org/viewvc?rev=803154&view=rev
Log:
UIMA-1477 Added more debugging msgs to determine cause of the hang
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java?rev=803154&r1=803153&r2=803154&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java Tue Aug 11 15:24:58 2009
@@ -274,7 +274,8 @@
if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.FINEST)) {
UIMAFramework.getLogger(CLASS_NAME).logrb(Level.FINEST, CLASS_NAME.getName(), "collectionProcessingComplete", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_app_cpc_request_FINEST", new Object[] {});
}
-
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(), "collectionProcessingComplete", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_in_cpc_INFO",
+ new Object[] { outstandingCasRequests.get(), totalCasRequestsSentBetweenCpCs.get() });
// If the client was initialized but never sent any CASes its cpcReadySemaphore
// must be first explicitly released to enable the code to send CPC to a service.
// The semaphore is initially acquired in the initialize(Map) method and typically
@@ -1104,6 +1105,8 @@
{
// Received a reply, decrement number of outstanding CASes
long outstandingCasCount = outstandingCasRequests.decrementAndGet();
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(), "handleProcessReply", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_handling_process_reply_INFO",
+ new Object[] { message.getStringProperty(AsynchAEMessage.CasReference), outstandingCasCount, totalCasRequestsSentBetweenCpCs });
if ( outstandingCasCount == 0) {
cpcReadySemaphore.release();
}