dimawo.middleware.communication.outputStream
Class MessageOutputStreamAccessor

java.lang.Object
  dimawo.middleware.communication.outputStream.MessageOutputStreamAccessor

All Implemented Interfaces:

MOSAccessorInterface, Comparable<MessageOutputStreamAccessor>

public class MessageOutputStreamAccessor
extends Object
implements MOSAccessorInterface, Comparable<MessageOutputStreamAccessor>

Constructor Summary

MessageOutputStreamAccessor(int uid, Communicator com, MOSCallBack cb, MessageOutputStream mos)

Method Summary

void	close()
int	compareTo(MessageOutputStreamAccessor other)
void	confirmClose(boolean success)
DAId	getDestinationDAId()
void	signalBroken()
void	writeBlockingMessage(Message m)
void	writeNonBlockingMessage(Message m)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageOutputStreamAccessor

public MessageOutputStreamAccessor(int uid,
                                   Communicator com,
                                   MOSCallBack cb,
                                   MessageOutputStream mos)

Method Detail

writeBlockingMessage

public void writeBlockingMessage(Message m)
                          throws IOException,
                                 InterruptedException

Specified by:

writeBlockingMessage in interface MOSAccessorInterface

Throws:

IOException

InterruptedException

writeNonBlockingMessage

public void writeNonBlockingMessage(Message m)

Specified by:

writeNonBlockingMessage in interface MOSAccessorInterface

close

public void close()
           throws IOException,
                  InterruptedException

Specified by:

close in interface MOSAccessorInterface

Throws:

IOException

InterruptedException

confirmClose

public void confirmClose(boolean success)

compareTo

public int compareTo(MessageOutputStreamAccessor other)

Specified by:

compareTo in interface Comparable<MessageOutputStreamAccessor>

signalBroken

public void signalBroken()

getDestinationDAId

public DAId getDestinationDAId()

Specified by:

getDestinationDAId in interface MOSAccessorInterface