This code was partially copy/pasted from the oplog slurper, but the exception handling
was not changed for the new environment: there is no retrying here.
drop the unneeded Thread#sleep() calls
drop the unneeded early returns
change exception logging from #info() with #error()
The calls to Thread#interrupt() still make sense, as the slurper runs inside a thread,
and that one needs to stop as well.
This code was partially copy/pasted from the oplog slurper, but the exception handling was not changed for the new environment: there is no retrying here.
The calls to Thread#interrupt() still make sense, as the slurper runs inside a thread, and that one needs to stop as well.