org.hobbit.core.components.stream

Class AbstractStreamingTaskGenerator.GeneratedDataHandler

java.lang.Object

org.hobbit.core.components.stream.AbstractStreamingTaskGenerator.GeneratedDataHandler

All Implemented Interfaces:

IncomingStreamHandler

Enclosing class:

AbstractStreamingTaskGenerator

protected class AbstractStreamingTaskGenerator.GeneratedDataHandler
extends Object
implements IncomingStreamHandler

A simple internal handler class that calls AbstractStreamingTaskGenerator.generateTask(InputStream) with the given InputStream.

Author:

Michael Röder (roeder@informatik.uni-leipzig.de)

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GeneratedDataHandler()

Method Summary

Modifier and Type	Method and Description
void	handleIncomingStream(String streamId, InputStream stream) Method handling the given InputStream.

Methods inherited from class java.lang.Object

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

Constructor Detail

GeneratedDataHandler

protected GeneratedDataHandler()

Method Detail

handleIncomingStream

public void handleIncomingStream(String streamId,
                                 InputStream stream)

Description copied from interface: IncomingStreamHandler

Method handling the given InputStream. Note that it is assumed that the method blocks until the input stream is read. After the program leaves the method, the stream is closed.

Specified by:

handleIncomingStream in interface IncomingStreamHandler

Parameters:

streamId - the id of the stream

stream - the input stream containing the incoming data