org.globus.cog.karajan.workflow.service.channels
Interface KarajanChannel

All Known Implementing Classes:

AbstractKarajanChannel, AbstractSocketChannel, AbstractStreamKarajanChannel, BufferingChannel, GSSSocketChannel, MetaChannel, NullChannel, PlainSocketChannel

public interface KarajanChannel

Field Summary

static int	ERROR_FLAG
static int	FINAL_FLAG
static int	REPLY_FLAG

Method Summary

void	close()
int	decLongTermUsageCount()
int	decUsageCount()
ChannelContext	getChannelContext()
RequestManager	getRequestManager()
UserContext	getUserContext()
int	incLongTermUsageCount()
int	incUsageCount()
boolean	isClient()
boolean	isOffline()
void	registerCommand(Command command)
void	registerHandler(RequestHandler handler, int tag)
void	sendTaggedData(int i, boolean fin, byte[] bytes)
void	sendTaggedData(int i, int flags, byte[] bytes)
void	sendTaggedReply(int i, byte[] buf, boolean fin, boolean errorFlag)
void	setChannelContext(ChannelContext context)
void	setLocalShutdown()
void	shutdown()
void	unregisterCommand(Command cmd)
void	unregisterHandler(int tag)

Field Detail

REPLY_FLAG

static final int REPLY_FLAG

See Also:

Constant Field Values

FINAL_FLAG

static final int FINAL_FLAG

See Also:

Constant Field Values

ERROR_FLAG

static final int ERROR_FLAG

See Also:

Constant Field Values

Method Detail

sendTaggedData

void sendTaggedData(int i,
                    boolean fin,
                    byte[] bytes)

sendTaggedData

void sendTaggedData(int i,
                    int flags,
                    byte[] bytes)

registerCommand

void registerCommand(Command command)
                     throws ProtocolException

Throws:

ProtocolException

getUserContext

UserContext getUserContext()

unregisterHandler

void unregisterHandler(int tag)

sendTaggedReply

void sendTaggedReply(int i,
                     byte[] buf,
                     boolean fin,
                     boolean errorFlag)

registerHandler

void registerHandler(RequestHandler handler,
                     int tag)

getRequestManager

RequestManager getRequestManager()

incUsageCount

int incUsageCount()

decUsageCount

int decUsageCount()

shutdown

void shutdown()

close

void close()

setLocalShutdown

void setLocalShutdown()

getChannelContext

ChannelContext getChannelContext()

setChannelContext

void setChannelContext(ChannelContext context)

isOffline

boolean isOffline()

unregisterCommand

void unregisterCommand(Command cmd)

incLongTermUsageCount

int incLongTermUsageCount()

decLongTermUsageCount

int decLongTermUsageCount()

isClient

boolean isClient()