public class RetryHelper extends Object
A helper class which contains methods related to retrying operations.
Constructor and Description |
---|
RetryHelper() |
Modifier and Type | Method and Description |
---|---|
static void |
retry(CouchbaseRequest request,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Always retry the request and send it into the response buffer.
|
static void |
retryOrCancel(CoreEnvironment environment,
CouchbaseRequest request,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Either retry or cancel a request, based on the strategy used.
|
public static void retryOrCancel(CoreEnvironment environment, CouchbaseRequest request, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Either retry or cancel a request, based on the strategy used.
environment
- the core environment for context.request
- the request to either retry or cancel.responseBuffer
- the response buffer where to maybe retry on.public static void retry(CouchbaseRequest request, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Always retry the request and send it into the response buffer.
request
- the request to retryresponseBuffer
- the response buffer to send it into.Copyright © 2018 Couchbase, Inc.. All rights reserved.