com.couchbase.lite.replicator

Class RemoteRequestRetry<T>

java.lang.Object

com.couchbase.lite.replicator.RemoteRequestRetry<T>

All Implemented Interfaces:

CustomFuture<T>, java.util.concurrent.Future<T>

public class RemoteRequestRetry<T>
extends java.lang.Object
implements CustomFuture<T>

Wraps a RemoteRequest with the ability to retry the request

Huge caveat: this cannot work on a single threaded requestExecutor, since it blocks while the "subrequests" are in progress, and during the sleeps in between the retries.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RemoteRequestRetry.RemoteRequestType The kind of RemoteRequest that will be created on each retry attempt

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<java.lang.String,java.lang.Object>	attachments
protected Authenticator	authenticator
protected java.util.Map<java.lang.String,java.lang.Object>	body
protected HttpClientFactory	clientFactory
static int	MAX_RETRIES
protected java.lang.String	method
protected RemoteRequestCompletion	onCompletionCaller
protected RemoteRequestCompletion	onPreCompletionCaller
protected java.util.concurrent.ExecutorService	requestExecutor
protected java.util.Map<java.lang.String,java.lang.Object>	requestHeaders
static int	RETRY_DELAY_MS
static java.lang.String	TAG
protected java.net.URL	url
protected java.util.concurrent.ScheduledExecutorService	workExecutor

Constructor Summary

Constructors

Constructor and Description

RemoteRequestRetry(RemoteRequestRetry.RemoteRequestType requestType, java.util.concurrent.ScheduledExecutorService requestExecutor, java.util.concurrent.ScheduledExecutorService workExecutor, HttpClientFactory clientFactory, java.lang.String method, java.net.URL url, boolean syncGateway, boolean cancelable, java.util.Map<java.lang.String,java.lang.Object> body, java.util.Map<java.lang.String,java.lang.Object> attachments, Database db, java.util.Map<java.lang.String,java.lang.Object> requestHeaders, RemoteRequestCompletion onCompletionCaller)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
void	setAuthenticator(Authenticator authenticator)
void	setDontLog404(boolean dontLog404)
void	setOnPreCompletionCaller(RemoteRequestCompletion onPreCompletionCaller)
void	setQueue(java.util.Queue queue)
CustomFuture	submit()
CustomFuture	submit(boolean gzip)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TAG

public static final java.lang.String TAG

See Also:

Constant Field Values

MAX_RETRIES

public static int MAX_RETRIES

RETRY_DELAY_MS

public static int RETRY_DELAY_MS

workExecutor

protected java.util.concurrent.ScheduledExecutorService workExecutor

requestExecutor

protected java.util.concurrent.ExecutorService requestExecutor

clientFactory

protected final HttpClientFactory clientFactory

method

protected java.lang.String method

url

protected java.net.URL url

body

protected java.util.Map<java.lang.String,java.lang.Object> body

attachments

protected java.util.Map<java.lang.String,java.lang.Object> attachments

authenticator

protected Authenticator authenticator

onCompletionCaller

protected RemoteRequestCompletion onCompletionCaller

onPreCompletionCaller

protected RemoteRequestCompletion onPreCompletionCaller

requestHeaders

protected java.util.Map<java.lang.String,java.lang.Object> requestHeaders

Constructor Detail

RemoteRequestRetry

public RemoteRequestRetry(RemoteRequestRetry.RemoteRequestType requestType,
                          java.util.concurrent.ScheduledExecutorService requestExecutor,
                          java.util.concurrent.ScheduledExecutorService workExecutor,
                          HttpClientFactory clientFactory,
                          java.lang.String method,
                          java.net.URL url,
                          boolean syncGateway,
                          boolean cancelable,
                          java.util.Map<java.lang.String,java.lang.Object> body,
                          java.util.Map<java.lang.String,java.lang.Object> attachments,
                          Database db,
                          java.util.Map<java.lang.String,java.lang.Object> requestHeaders,
                          RemoteRequestCompletion onCompletionCaller)

Method Detail

submit

public CustomFuture submit()

submit

public CustomFuture submit(boolean gzip)

Parameters:

gzip - true - send gzipped request

setAuthenticator

public void setAuthenticator(Authenticator authenticator)

setOnPreCompletionCaller

public void setOnPreCompletionCaller(RemoteRequestCompletion onPreCompletionCaller)

setDontLog404

public void setDontLog404(boolean dontLog404)

setQueue

public void setQueue(java.util.Queue queue)

Specified by:

setQueue in interface CustomFuture<T>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<T>

get

public T get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public T get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<T>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException