org.hobbit.core.components.stream

Class AbstractStreamingSystemAdapter.GeneratedTaskHandler

java.lang.Object

org.hobbit.core.components.stream.AbstractStreamingSystemAdapter.GeneratedTaskHandler

All Implemented Interfaces:

IncomingStreamHandler

Enclosing class:

AbstractStreamingSystemAdapter

protected class AbstractStreamingSystemAdapter.GeneratedTaskHandler
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	GeneratedTaskHandler()

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

GeneratedTaskHandler

protected GeneratedTaskHandler()

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