com.bigdata.io

Class ObjectSocketChannelStream

java.lang.Object

com.bigdata.io.ObjectSocketChannelStream

public class ObjectSocketChannelStream
extends Object

Utility class that provides dual Channel/ObjectStream access.

Author:

Martyn Cutcher

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
ObjectSocketChannelStream(ByteChannel channel)

Method Summary

Methods

Modifier and Type	Method and Description
ByteChannel	getChannel()
ObjectInputStream	getInputStream()
ObjectOutputStream	getOutputStream()
static InputStream	newInputStream(ByteChannel channel)
static OutputStream	newOutputStream(ByteChannel channel)
byte[]	readByteArray(int sze)
Object	readObject()
void	write(ByteBuffer tmp)
void	writeObject(Object obj)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

Constructor Detail

ObjectSocketChannelStream

public ObjectSocketChannelStream(ByteChannel channel)

Method Detail

getChannel

public ByteChannel getChannel()

writeObject

public void writeObject(Object obj)
                 throws IOException

Throws:

IOException

readObject

public Object readObject()
                  throws IOException

Throws:

IOException

getInputStream

public ObjectInputStream getInputStream()

getOutputStream

public ObjectOutputStream getOutputStream()

readByteArray

public byte[] readByteArray(int sze)
                     throws IOException

Throws:

IOException

write

public void write(ByteBuffer tmp)
           throws IOException

Throws:

IOException

newOutputStream

public static OutputStream newOutputStream(ByteChannel channel)

newInputStream

public static InputStream newInputStream(ByteChannel channel)