Posted a properly working version.
The previous version had a couple thread synchronisation issues that should be fixed in this.
Also changed the headers on both file to the apache header. However, the cursor.java is actually more or less the same as the one from OG(the only real change are with the packaging of events), so I'm not entirely sure of what the proper header for that is?
Also added in multiple file support.
Things not implemented that were in OG(I'll get around to these once I'm happy things work well as is. Running an initial test on a few G a day of data flow):
- Custom delimiters
- directory tailing
An area of concern that remains is with the handling of interrupts:
- In process() i'm currently just returning Status.BACKOFF if the poll gets interrupted but thinking this may have to be changed to an EventDeliveryException. I'm not particularly happy with either choice though and would be curious of other peoples opionions on the matter.