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/07/14 23:31:47 UTC
svn commit: r794074 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/ClientServiceDelegate.java
Author: cwiklik
Date: Tue Jul 14 21:31:47 2009
New Revision: 794074
URL: http://svn.apache.org/viewvc?rev=794074&view=rev
Log:
UIMA-1436 Modified handleError() to cancel timer and return if the client has been stopped
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=794074&r1=794073&r2=794074&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 Tue Jul 14 21:31:47 2009
@@ -67,10 +67,14 @@
String casReferenceId = null;
CAS cas = null;
ClientRequest cachedRequest = null;
-
+ if ( !clientUimaAsEngine.running ) {
+ cancelDelegateTimer();
+ return;
+ }
int command = ((Integer)errorContext.get(AsynchAEMessage.Command)).intValue();
try {
if ( e instanceof MessageTimeoutException) {
+ cancelDelegateTimer();
switch( command ) {
case AsynchAEMessage.Process:
casReferenceId = (String)errorContext.get(AsynchAEMessage.CasReference);