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/01/22 22:25:30 UTC
svn commit: r736800 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/ClientServiceDelegate.java
Author: cwiklik
Date: Thu Jan 22 13:25:30 2009
New Revision: 736800
URL: http://svn.apache.org/viewvc?rev=736800&view=rev
Log:
UIMA-1127 Fixed how Ping Timeout is Handled
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/ClientServiceDelegate.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/ClientServiceDelegate.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/ClientServiceDelegate.java?rev=736800&r1=736799&r2=736800&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/ClientServiceDelegate.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/ClientServiceDelegate.java Thu Jan 22 13:25:30 2009
@@ -63,8 +63,6 @@
if ( e instanceof MessageTimeoutException) {
switch( command ) {
case AsynchAEMessage.Process:
- System.out.println(">>>>> Client Process Timed Out");
- clientUimaAsEngine.clientSideJmxStats.incrementProcessTimeoutErrorCount();
casReferenceId = (String)errorContext.get(AsynchAEMessage.CasReference);
if ( casReferenceId != null ) {
cachedRequest =(ClientRequest)clientUimaAsEngine.clientCache.get(casReferenceId);
@@ -75,7 +73,16 @@
if (cachedRequest != null && cachedRequest.isRemote()) {
cas = cachedRequest.getCAS();
}
+ if ( isAwaitingPingReply() ) {
+ System.out.println(">>>>> Client Ping Timedout");
+ clientUimaAsEngine.notifyOnTimout(cas, clientUimaAsEngine.getEndPointName(), BaseUIMAAsynchronousEngineCommon_impl.PingTimeout, casReferenceId);
+ System.out.println("Stopping Uima AS Client API. Service Not Responding To a Ping.");
+ clientUimaAsEngine.stop();
+ break;
+ }
}
+ clientUimaAsEngine.clientSideJmxStats.incrementProcessTimeoutErrorCount();
+ System.out.println(">>>>> Client Process Timed Out");
if ( !isAwaitingPingReply()) {
setAwaitingPingReply();
System.out.println(">>>>> Client Sending Ping");