public BatchFailureListener < QueryBatch > initializeRetryListener ( QueryBatchListener queryBatchListener ) { if ( ! retryListenersSet . contains ( queryBatchListener ) ) { synchronized ( this ) { if ( ! retryListenersSet . contains ( queryBatchListener ) ) { RetryListener retryListener = new RetryListener ( queryBatchListener ) ; retryListenersSet . add ( queryBatchListener ) ; return retryListener ; } } } return null ; }
Initializes the RetryListener for the given QueryBatchListener .