Author: cwiklik
Date: Fri Mar 4 14:39:33 2011
New Revision: 1077969
URL: http://svn.apache.org/viewvc?rev=1077969&view=rev
Log:
UIMA-2083 Modified to use type of serialization defined for each delegate in a
deployment descriptor.
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
URL:
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java?rev=1077969&r1=1077968&r2=1077969&view=diff
==============================================================================
---
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
(original)
+++
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
Fri Mar 4 14:39:33 2011
@@ -1462,13 +1462,14 @@ public class JmsOutputChannel implements
if (aSerializedCAS != null) {
msgSize = ((String)aSerializedCAS).length();
}
-
+ tm.setIntProperty(AsynchAEMessage.Payload,
AsynchAEMessage.XMIPayload);
} else {
// Create empty JMS Bytes Message
tm = endpointConnection.produceByteMessage((byte[])aSerializedCAS);
if (aSerializedCAS != null) {
msgSize = ((byte[])aSerializedCAS).length;
}
+ tm.setIntProperty(AsynchAEMessage.Payload,
AsynchAEMessage.BinaryPayload);
}
} catch (AsynchAEException ex) {
UIMAFramework.getLogger(CLASS_NAME).logrb(
@@ -1481,7 +1482,6 @@ public class JmsOutputChannel implements
anEndpoint.getDestination(), brokerConnectionURL,
entry.getInputCasReferenceId() == null ? "" : entry.getInputCasReferenceId(),
entry.getCasReferenceId(), 0, ex });
return;
}
- tm.setIntProperty(AsynchAEMessage.Payload,
AsynchAEMessage.BinaryPayload);
// Add Cas Reference Id to the outgoing JMS Header
tm.setStringProperty(AsynchAEMessage.CasReference,
entry.getCasReferenceId());
// Add common properties to the JMS Header
