svn commit: r927135 - /incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessResponseHandler.java

[cw...@apache.org]

Author: cwiklik
Date: Wed Mar 24 17:51:51 2010
New Revision: 927135

URL: http://svn.apache.org/viewvc?rev=927135&view=rev
Log:
UIMA-1749 Modified to fetch dedicated Serializer instance for a given thread

Modified:
    incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessResponseHandler.java

Modified: incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessResponseHandler.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessResponseHandler.java?rev=927135&r1=927134&r2=927135&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessResponseHandler.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/handler/input/ProcessResponseHandler.java Wed Mar 24 17:51:51 2010
@@ -23,6 +23,7 @@ import java.rmi.RemoteException;
 
 import org.apache.uima.UIMAException;
 import org.apache.uima.UIMAFramework;
+import org.apache.uima.aae.SerializerCache;
 import org.apache.uima.aae.UIMAEE_Constants;
 import org.apache.uima.aae.UimaSerializer;
 import org.apache.uima.aae.InProcessCache.CacheEntry;
@@ -53,8 +54,6 @@ import org.apache.uima.util.Level;
 public class ProcessResponseHandler extends HandlerBase {
   private static final Class CLASS_NAME = ProcessResponseHandler.class;
 
-  private UimaSerializer uimaSerializer = new UimaSerializer();
-
   public ProcessResponseHandler(String aName) {
     super(aName);
   }
@@ -251,6 +250,7 @@ public class ProcessResponseHandler exte
       } else { // Processing a reply from a non-parallel delegate (binary or delta xmi or xmi)
         String serializationStrategy = endpointWithTimer.getSerializer();
         if (serializationStrategy.equals("binary")) {
+          UimaSerializer uimaSerializer = SerializerCache.lookupSerializerByThreadId();
           byte[] binaryData = aMessageContext.getByteMessage();
           uimaSerializer.deserializeCasFromBinary(binaryData, cas);
         } else {
@@ -341,6 +341,7 @@ public class ProcessResponseHandler exte
     XmiSerializationSharedData deserSharedData;
     deserSharedData = getController().getInProcessCache().getCacheEntryForCAS(casReferenceId)
             .getDeserSharedData();
+    UimaSerializer uimaSerializer = SerializerCache.lookupSerializerByThreadId();
     uimaSerializer.deserializeCasFromXmi(xmi, cas, deserSharedData, true, highWaterMark, allow);
   }
 
@@ -353,6 +354,7 @@ public class ProcessResponseHandler exte
       deserSharedData = new XmiSerializationSharedData();
       entry.setXmiSerializationData(deserSharedData);
     }
+    UimaSerializer uimaSerializer = SerializerCache.lookupSerializerByThreadId();
     uimaSerializer.deserializeCasFromXmi(xmi, cas, deserSharedData, true, -1);
   }