com.toolsverse.io

Interface StreamingProcessor

public interface StreamingProcessor

A common interface for IoProcessor classes which can stream data and consume data from streams.

Since:

5.9

Version:

1.0

Method Summary

Modifier and Type	Method and Description
boolean	consume(StreamingConnector connector, StreamingPackage streamingPackage) Consume data from stream.
void	prepareToStream() Prepare to stream.
void	stream(StreamingConnector connector, ProducerPackage producerPackage) Send data to stream.

Method Detail

consume

boolean consume(StreamingConnector connector,
                StreamingPackage streamingPackage)
         throws Exception

Consume data from stream.

Parameters:

connector - the connector

streamingPackage - the streaming package

Returns:

true, if the number of streamed records > 0

Throws:

Exception - in case of any error

prepareToStream

void prepareToStream()
              throws Exception

Prepare to stream.

Throws:

Exception - in case of any error

stream

void stream(StreamingConnector connector,
            ProducerPackage producerPackage)
     throws Exception

Send data to stream.

Parameters:

producerPackage - the producer package

Throws:

Exception - in case of any error