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(),