Igniters,

I have implemented timeout in DataStreamer by issue IGNITE-3055
<https://issues.apache.org/jira/browse/IGNITE-3055>(*IgniteDataStreamer
can't be timed out*).

That lead the change public API:

1) Added set and get methods (IgniteDataStreamer.timeout(long) and
IgniteDataStreamer.timeout()) for establish. Default value is -1, means
unlimited time.

2) Added new TimeoutException (inherited IgniteException). The exception
will thrown when timeout will be reached (may be take place in
IgniteDataStreamer.addData, IgniteDataStreamer.close and
IgniteDataStreamer.flash operations).

Dmitry, colleagues, please comment or approve.

Reply via email to