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

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

All Implemented Interfaces:

KarajanChannel

Direct Known Subclasses:

AbstractSocketChannel

public abstract class AbstractStreamKarajanChannel
extends AbstractKarajanChannel

Field Summary

static org.apache.log4j.Logger

logger

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

ERROR_FLAG, FINAL_FLAG, REPLY_FLAG

Constructor Summary

protected

AbstractStreamKarajanChannel(RequestManager requestManager, ChannelContext channelContext)

Method Summary

String	getEndpoint()
protected InputStream	getInputStream()
protected OutputStream	getOutputStream()
protected void	mainLoop()
void	sendTaggedData(int tag, int flags, byte[] data)
void	setEndpoint(String endpoint)
protected void	setInputStream(InputStream inputStream)
protected void	setOutputStream(OutputStream outputStream)

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, toString, wait, wait, wait

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

getUserContext, isOffline

Field Detail

logger

public static final org.apache.log4j.Logger logger

Constructor Detail

AbstractStreamKarajanChannel

protected AbstractStreamKarajanChannel(RequestManager requestManager,
                                       ChannelContext channelContext)

Method Detail

getInputStream

protected InputStream getInputStream()

setInputStream

protected void setInputStream(InputStream inputStream)

getOutputStream

protected OutputStream getOutputStream()

setOutputStream

protected void setOutputStream(OutputStream outputStream)

getEndpoint

public String getEndpoint()

setEndpoint

public void setEndpoint(String endpoint)

sendTaggedData

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

mainLoop

protected void mainLoop()
                 throws IOException

Throws:

IOException