public interface StreamingProcessor
IoProcessor
classes which can stream data and consume data from streams.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.
|
boolean consume(StreamingConnector connector, StreamingPackage streamingPackage) throws Exception
connector
- the connectorstreamingPackage
- the streaming packageException
- in case of any errorvoid prepareToStream() throws Exception
Exception
- in case of any errorvoid stream(StreamingConnector connector, ProducerPackage producerPackage) throws Exception
producerPackage
- the producer packageException
- in case of any errorCopyright © 2010-2020 Toolsverse. All Rights Reserved.