net.metanotion.util.observers
Class ChannelBusMessageOutputStream

java.lang.Object
  net.metanotion.util.observers.ChannelBusMessageOutputStream

All Implemented Interfaces:

ObjectOutputStream<Message>

public final class ChannelBusMessageOutputStream
extends java.lang.Object
implements ObjectOutputStream<Message>

Constructor Summary

ChannelBusMessageOutputStream(java.lang.Object channel, MessageBusManager bus)

Method Summary

void	close() Close the stream.
void	flush() Flush any "pending" "writes" in the stream.
void	write(Message m) Write an object to the stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelBusMessageOutputStream

public ChannelBusMessageOutputStream(java.lang.Object channel,
                                     MessageBusManager bus)

Method Detail

write

public void write(Message m)
           throws ObjectStreamClosedException

Description copied from interface: ObjectOutputStream

Write an object to the stream.

Specified by:

write in interface ObjectOutputStream<Message>

Parameters:

m - the object to write.

Throws:

ObjectStreamClosedException - if the stream has been closed.

close

public void close()

Description copied from interface: ObjectOutputStream

Close the stream.

Specified by:

close in interface ObjectOutputStream<Message>

flush

public void flush()

Description copied from interface: ObjectOutputStream

Flush any "pending" "writes" in the stream. The semantics of this call are subject to the nature of the stream. If it is relevant, this should ensure that any I/O buffers are flushed to persistent storage or flushed to the network. However, it is acceptable for an implmentation to stub this out and do nothing with it. If implemented, this method must block until its I/O operations are completed.

Specified by:

flush in interface ObjectOutputStream<Message>