Closed
Description
current ConnectionSync.write() method use future, and get result blocked
public Message write(final Message message, final Collection<Chunk> chunks) {
return task.get();
}
we need timeout setting on task get for long running query/operation, such as:
public Message write(final Message message, final Collection<Chunk> chunks) {
return task.get(2 * 60, TimeUnit.SECONDS);
}
there're already a timeout setting on ConnectionSync.Builder, but that's for connection, not for write.
Do you guys want to support this feature, or can you give reason why not?
Metadata
Metadata
Assignees
Labels
No labels