[Cogkit-svn] SF.net SVN: cogkit:[2210] trunk/current/src/cog/modules/karajan/src/org/ globus/cog/karajan/workflow/service/channels/AbstractKarajanChannel.java

[<ha...@us...>]

Revision: 2210
          http://cogkit.svn.sourceforge.net/cogkit/?rev=2210&view=rev
Author:   hategan
Date:     2008-10-02 18:38:40 +0000 (Thu, 02 Oct 2008)

Log Message:
-----------
allow commands to see whether data is part of an error or not

Modified Paths:
--------------
    trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/AbstractKarajanChannel.java

Modified: trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/AbstractKarajanChannel.java
===================================================================
--- trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/AbstractKarajanChannel.java	2008-10-02 18:38:07 UTC (rev 2209)
+++ trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/AbstractKarajanChannel.java	2008-10-02 18:38:40 UTC (rev 2210)
@@ -97,6 +97,7 @@
 	}
 
 	public void unregisterCommand(Command cmd) {
+		logger.info("Unregistering " + cmd);
 		context.unregisterCommand(cmd);
 	}
 
@@ -274,6 +275,9 @@
 		Command cmd = getChannelContext().getRegisteredCommand(tag);
 		if (cmd != null) {
 			try {
+			    if (error) {
+			        cmd.raiseErrorFlag();
+			    }
 				cmd.replyReceived(data);
 				if (fin) {
 					if (logger.isInfoEnabled()) {


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.