You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by ea...@apache.org on 2008/10/24 22:25:18 UTC

svn commit: r707733 - /incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java

Author: eae
Date: Fri Oct 24 13:25:18 2008
New Revision: 707733

URL: http://svn.apache.org/viewvc?rev=707733&view=rev
Log:
UIMA-1214

Modified:
    incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java

Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java?rev=707733&r1=707732&r2=707733&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java Fri Oct 24 13:25:18 2008
@@ -1077,7 +1077,13 @@
         //  Serialize CAS for remote Delegates
         String serializer = anEndpoint.getSerializer();
         if ( serializer.equals("binary")) {
-          serializedCAS = uimaSerializer.serializeCasToBinary(cas);
+          if (entry.acceptsDeltaCas())  {
+            serializedCAS = uimaSerializer.serializeCasToBinary(cas, entry.getMarker());
+            entry.setSentDeltaCas(true);
+          } else {
+            serializedCAS = uimaSerializer.serializeCasToBinary(cas);
+            entry.setSentDeltaCas(false);
+          }
         } else {
           if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
             UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(),