You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by jo...@apache.org on 2009/07/02 10:48:38 UTC
svn commit: r790502 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java
Author: joern
Date: Thu Jul 2 08:48:38 2009
New Revision: 790502
URL: http://svn.apache.org/viewvc?rev=790502&view=rev
Log:
UIMA-1409
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java?rev=790502&r1=790501&r2=790502&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-camel/src/main/java/org/apache/uima/camel/UimaAsProducer.java Thu Jul 2 08:48:38 2009
@@ -73,9 +73,13 @@
UimaASProcessStatusImpl statusImpl = (UimaASProcessStatusImpl) aStatus;
String referenceId = statusImpl.getCasReferenceId();
-
- ExchangeAsyncCallbackPair exchangeCallbackPair = intermediateMap.remove(referenceId);
-
+
+ ExchangeAsyncCallbackPair exchangeCallbackPair;
+
+ synchronized (intermediateMap) {
+ exchangeCallbackPair = intermediateMap.remove(referenceId);
+ }
+
if (exchangeCallbackPair != null) {
if (aStatus.isException()) {