org.globus.cog.karajan.workflow.service.channels
Class BufferingChannel

java.lang.Object
  org.globus.cog.karajan.workflow.service.channels.AbstractKarajanChannel
      org.globus.cog.karajan.workflow.service.channels.BufferingChannel

All Implemented Interfaces:

KarajanChannel, Purgeable

public class BufferingChannel
extends AbstractKarajanChannel
implements Purgeable

Used for buffering of commands with a polling configuration. Which means that reply timeouts should be a channel thing, and should be considered from the time of the actual send

Nested Class Summary

static class

BufferingChannel.DataEntry

Field Summary

Fields inherited from interface org.globus.cog.karajan.workflow.service.channels.KarajanChannel

ERROR_FLAG, FINAL_FLAG, REPLY_FLAG

Constructor Summary

BufferingChannel(ChannelContext channelContext)

Method Summary

UserContext	getUserContext()
boolean	isOffline()
void	purge(KarajanChannel channel)
void	sendTaggedData(int tag, int flags, byte[] data)
String	toString()

Methods inherited from class org.globus.cog.karajan.workflow.service.channels.AbstractKarajanChannel

close, decLongTermUsageCount, decUsageCount, getChannelContext, getLongTermUsageCount, getRequestManager, incLongTermUsageCount, incUsageCount, isClient, isClosed, isLocalShutdown, ppByteBuf, readFromStream, readFromStream, registerCommand, registerHandler, sendTaggedData, sendTaggedReply, sendTaggedReply, setChannelContext, setLocalShutdown, shutdown, unregisterCommand, unregisterHandler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BufferingChannel

public BufferingChannel(ChannelContext channelContext)

Method Detail

sendTaggedData

public void sendTaggedData(int tag,
                           int flags,
                           byte[] data)

Specified by:

sendTaggedData in interface KarajanChannel

getUserContext

public UserContext getUserContext()

Specified by:

getUserContext in interface KarajanChannel

purge

public void purge(KarajanChannel channel)
           throws IOException

Specified by:

purge in interface Purgeable

Throws:

IOException

isOffline

public boolean isOffline()

Specified by:

isOffline in interface KarajanChannel

toString

public String toString()

Overrides:

toString in class Object