com.asakusafw.windgate.stream

Class StreamDrainDriver<T>

java.lang.Object

com.asakusafw.windgate.stream.StreamDrainDriver<T>

Type Parameters:

T - type of data model objects

All Implemented Interfaces:

DrainDriver<T>, Preparable, Closeable, AutoCloseable

public class StreamDrainDriver<T>
extends Object
implements DrainDriver<T>

An implementation of SourceDriver using binary InputStream.

Since:

0.2.4

Constructor Summary

Constructors

Constructor and Description
StreamDrainDriver(String resourceName, String processName, OutputStreamProvider streamProvider, DataModelStreamSupport<? super T> streamSupport) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close() Disposes this object.
void	prepare() Prepares this driver to invoke DrainDriver.put(Object) method.
void	put(T object) Puts each data model object into the connected resource.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamDrainDriver

public StreamDrainDriver(String resourceName,
                         String processName,
                         OutputStreamProvider streamProvider,
                         DataModelStreamSupport<? super T> streamSupport)

Creates a new instance.

Parameters:

resourceName - original resource name

processName - current process name

streamProvider - provides target OutputStream

streamSupport - converts data model objects into binary data

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

prepare

public void prepare()
             throws IOException

Description copied from interface: DrainDriver

Prepares this driver to invoke DrainDriver.put(Object) method. This method will be invoked before DrainDriver.put(Object) only once. This operation can execute only on the same thread as created this object.

Specified by:

prepare in interface DrainDriver<T>

Specified by:

prepare in interface Preparable

Throws:

IOException - if failed to begin

put

public void put(T object)
         throws IOException

Description copied from interface: DrainDriver

Puts each data model object into the connected resource. This operation can execute only on the same thread as created this object.

Specified by:

put in interface DrainDriver<T>

Parameters:

object - the data model object to be put

Throws:

IOException - if failed to put data

close

public void close()
           throws IOException

Description copied from interface: DrainDriver

Disposes this object. This operation can execute only on the same thread as created this object.

Specified by:

close in interface DrainDriver<T>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - if failed to connect