Author: cwiklik Date: Mon Sep 26 17:38:54 2011 New Revision: 1175970 URL: http://svn.apache.org/viewvc?rev=1175970&view=rev Log: UIMA-2239 synchronized cancelTimerForCasOrPurge()
Modified: uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/delegate/Delegate.java Modified: uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/delegate/Delegate.java URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/delegate/Delegate.java?rev=1175970&r1=1175969&r2=1175970&view=diff ============================================================================== --- uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/delegate/Delegate.java (original) +++ uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/delegate/Delegate.java Mon Sep 26 17:38:54 2011 @@ -136,7 +136,7 @@ public abstract class Delegate { return endpoint; } - public void cancelTimerForCasOrPurge(String casReferenceId) { + public synchronized void cancelTimerForCasOrPurge(String casReferenceId) { if ( timer != null && timer.getTimerCasId() != null && timer.getTimerCasId().equals(casReferenceId)) { //System.out.println("\n\n\t Canceled Timer For CAS:"+casReferenceId+" and Restarting Timer for the next oldest CAS in the outstanding list\n\n"); cancelDelegateTimer(); @@ -806,7 +806,7 @@ public abstract class Delegate { } return sb.toString(); } - private class DelegateTimer extends Timer { + private static class DelegateTimer extends Timer { String casReferenceId; Delegate delegate; public DelegateTimer(String threadName, boolean isDaemon, String casReferenceId, Delegate delegate) {