|
From: <ha...@us...> - 2008-10-02 18:39:19
|
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.
|