Github user rickysaltzer commented on the pull request:
https://github.com/apache/nifi/pull/91#issuecomment-150260104
@bbende I updated the review with a different approach to sending events.
After I started doing a lot of random disconnect testing, it appeared that the
`RiemannBatchClient` had some really odd behavior when it came to detecting a
down connection. Instead of using that, I'm using the regular `RiemannClient`
and batching them together myself. This way I can call the `deref()` on the
`IPromise` in order to detect connection failures, or timeouts.
If the connection drops while sending events, the processor will `yield()`
and attempt to re-connect on the next trigger until it can do so successfully.
I also added a test (`testFailedDeref`) to verify that this works, as well as
tested it internally with both `TCP` and `UDP`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
