Adding more robus failure handling to CollectorProcessor
retryBuilder with tests
Forgot test