You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/05/29 20:29:54 UTC
svn commit: r780061 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
Author: cwiklik
Date: Fri May 29 18:29:54 2009
New Revision: 780061
URL: http://svn.apache.org/viewvc?rev=780061&view=rev
Log:
UIMA-1358 Adds parent CAS id to reply msg containing an exception
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=780061&r1=780060&r2=780061&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 May 29 18:29:54 2009
@@ -883,7 +883,7 @@
*
* @throws AsynchAEException
*/
- public void sendReply(Throwable t, String aCasReferenceId, Endpoint anEndpoint, int aCommand ) throws AsynchAEException
+ public void sendReply(Throwable t, String aCasReferenceId, String aParentCasReferenceId, Endpoint anEndpoint, int aCommand ) throws AsynchAEException
{
anEndpoint.setReplyEndpoint(true);
try
@@ -924,6 +924,9 @@
if ( aCasReferenceId != null )
{
om.setStringProperty(AsynchAEMessage.CasReference, aCasReferenceId);
+ if ( aParentCasReferenceId != null ) {
+ om.setStringProperty(AsynchAEMessage.InputCasReference, aParentCasReferenceId);
+ }
}
if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.FINE)) {