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

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

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

Log Message:
-----------
removed replier since a separate sending thread is used anyway somewhere up the hierarchy

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

Modified: trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/GSSChannel.java
===================================================================
--- trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/GSSChannel.java	2008-10-02 18:36:55 UTC (rev 2208)
+++ trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/GSSChannel.java	2008-10-02 18:38:07 UTC (rev 2209)
@@ -13,13 +13,10 @@
 import java.net.URI;
 
 import org.apache.log4j.Logger;
-import org.globus.cog.karajan.workflow.events.EventBus;
 import org.globus.cog.karajan.workflow.service.FallbackAuthorization;
 import org.globus.cog.karajan.workflow.service.GSSService;
-import org.globus.cog.karajan.workflow.service.RemoteConfiguration;
 import org.globus.cog.karajan.workflow.service.RequestManager;
 import org.globus.cog.karajan.workflow.service.UserContext;
-import org.globus.cog.karajan.workflow.service.commands.ChannelConfigurationCommand;
 import org.globus.cog.karajan.workflow.service.commands.ShutdownCommand;
 import org.globus.gsi.GSIConstants;
 import org.globus.gsi.gssapi.GSSConstants;
@@ -41,7 +38,6 @@
 	private UserContext uc;
 	private boolean shuttingDown;
 	private Exception startException;
-	private Replier replier;
 	private int id;
 	private static int sid = 1;
 
@@ -61,14 +57,8 @@
 
 	private void init() {
 		id = sid++;
-		replier = new Replier(this);
-		EventBus.initialize();
 	}
 
-	public void sendTaggedReply(int tag, byte[] data, boolean fin, boolean err) {
-		EventBus.post(replier, new ReplyEvent(tag, data, fin, err));
-	}
-
 	public void start() throws ChannelException {
 		reconnect();
 		super.start();


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