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

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

All Implemented Interfaces:

KarajanChannel

public class MetaChannel
extends AbstractKarajanChannel

Field Summary

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

ERROR_FLAG, FINAL_FLAG, REPLY_FLAG

Constructor Summary

MetaChannel(ChannelContext channelContext)

MetaChannel(RequestManager requestManager, ChannelContext channelContext)

Method Summary

void	bind(KarajanChannel channel)
void	deactivateLater(int seconds)
Timer	getTimer()
UserContext	getUserContext()
boolean	isClient()
boolean	isOffline()
boolean	isShuttingDown()
void	poll(int seconds)
void	registerCommand(Command cmd)
void	registerHandler(RequestHandler handler, int tag)
void	sendTaggedData(int tag, int flags, byte[] data)
String	toString()
void	unregisterCommand(Command cmd)
void	unregisterHandler(int tag)

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

close, decLongTermUsageCount, decUsageCount, getChannelContext, getLongTermUsageCount, getRequestManager, incLongTermUsageCount, incUsageCount, isClosed, isLocalShutdown, ppByteBuf, readFromStream, readFromStream, sendTaggedData, sendTaggedReply, sendTaggedReply, setChannelContext, setLocalShutdown, shutdown

Methods inherited from class java.lang.Object

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

Constructor Detail

MetaChannel

public MetaChannel(ChannelContext channelContext)

MetaChannel

public MetaChannel(RequestManager requestManager,
                   ChannelContext channelContext)

Method Detail

sendTaggedData

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

registerCommand

public void registerCommand(Command cmd)
                     throws ProtocolException

Specified by:

registerCommand in interface KarajanChannel

Overrides:

registerCommand in class AbstractKarajanChannel

Throws:

ProtocolException

registerHandler

public void registerHandler(RequestHandler handler,
                            int tag)

Specified by:

registerHandler in interface KarajanChannel

Overrides:

registerHandler in class AbstractKarajanChannel

unregisterCommand

public void unregisterCommand(Command cmd)

Specified by:

unregisterCommand in interface KarajanChannel

Overrides:

unregisterCommand in class AbstractKarajanChannel

unregisterHandler

public void unregisterHandler(int tag)

Specified by:

unregisterHandler in interface KarajanChannel

Overrides:

unregisterHandler in class AbstractKarajanChannel

getUserContext

public UserContext getUserContext()

bind

public void bind(KarajanChannel channel)
          throws ChannelException

Throws:

ChannelException

isShuttingDown

public boolean isShuttingDown()

isOffline

public boolean isOffline()

deactivateLater

public void deactivateLater(int seconds)

getTimer

public Timer getTimer()

poll

public void poll(int seconds)

toString

public String toString()

Overrides:

toString in class Object

isClient

public boolean isClient()

Specified by:

isClient in interface KarajanChannel

Overrides:

isClient in class AbstractKarajanChannel