org.neodatis.odb.impl.core.server.layers.layer3.engine
Class DefaultMessageStreamer

java.lang.Object
  extended by org.neodatis.odb.impl.core.server.layers.layer3.engine.DefaultMessageStreamer
All Implemented Interfaces:
IMessageStreamer

public class DefaultMessageStreamer
extends java.lang.Object
implements IMessageStreamer

Author:
olivier

Constructor Summary
DefaultMessageStreamer(java.net.Socket socket)
           
DefaultMessageStreamer(java.lang.String host, int port, java.lang.String name)
           
 
Method Summary
 void clearCache()
           
 void close()
           
 Message read()
           
 void write(Message message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultMessageStreamer

public DefaultMessageStreamer(java.lang.String host,
                              int port,
                              java.lang.String name)

DefaultMessageStreamer

public DefaultMessageStreamer(java.net.Socket socket)
                       throws java.io.IOException
Throws:
java.io.IOException
Method Detail

close

public void close()
Specified by:
close in interface IMessageStreamer

write

public void write(Message message)
           throws java.lang.Exception
Specified by:
write in interface IMessageStreamer
Throws:
java.lang.Exception

clearCache

public void clearCache()
Specified by:
clearCache in interface IMessageStreamer

read

public Message read()
             throws java.lang.Exception
Specified by:
read in interface IMessageStreamer
Throws:
java.lang.Exception