com.couchbase.lite.replicator

Class ChangeTracker

java.lang.Object

com.couchbase.lite.replicator.ChangeTracker

All Implemented Interfaces:

java.lang.Runnable

public class ChangeTracker
extends java.lang.Object
implements java.lang.Runnable

Reads the continuous-mode _changes feed of a database, and sends the individual change entries to its client's changeTrackerReceivedChange()

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChangeTracker.ChangeTrackerMode

Field Summary

Fields

Modifier and Type	Field and Description
protected ChangeTrackerBackoff	backoff
protected java.util.Map<java.lang.String,java.lang.Object>	requestHeaders

Constructor Summary

Constructors

Constructor and Description
ChangeTracker(java.net.URL databaseURL, ChangeTracker.ChangeTrackerMode mode, boolean includeConflicts, java.lang.Object lastSequenceID, ChangeTrackerClient client)

Method Summary

Modifier and Type	Method and Description
java.lang.String	changesFeedPOSTBody()
java.util.Map<java.lang.String,java.lang.Object>	changesFeedPOSTBodyMap()
java.net.URL	getChangesFeedURL()
java.lang.String	getFeed()
long	getHeartbeatMilliseconds()
java.lang.Throwable	getLastError()
boolean	isActiveOnly()
boolean	isContinuous()
boolean	isRunning()
boolean	receivedChange(java.util.Map<java.lang.String,java.lang.Object> change)
boolean	receivedPollResponse(java.util.Map<java.lang.String,java.lang.Object> response)
void	run()
protected void	runLoop()
void	setActiveOnly(boolean activeOnly)
void	setAuthenticator(Authenticator authenticator) Set Authenticator for BASIC Authentication
void	setClient(ChangeTrackerClient client)
void	setContinuous(boolean continuous)
void	setDocIDs(java.util.List<java.lang.String> docIDs)
void	setFilterName(java.lang.String filterName)
void	setFilterParams(java.util.Map<java.lang.String,java.lang.Object> filterParams)
void	setPaused(boolean paused)
void	setRequestHeaders(java.util.Map<java.lang.String,java.lang.Object> requestHeaders)
void	setUpstreamError(java.lang.String message)
boolean	start()
void	stop()
java.lang.String	toString()
protected void	waitIfPaused()

Methods inherited from class java.lang.Object

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

Field Detail

requestHeaders

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

backoff

protected ChangeTrackerBackoff backoff

Constructor Detail

ChangeTracker

public ChangeTracker(java.net.URL databaseURL,
                     ChangeTracker.ChangeTrackerMode mode,
                     boolean includeConflicts,
                     java.lang.Object lastSequenceID,
                     ChangeTrackerClient client)

Method Detail

isContinuous

public boolean isContinuous()

setContinuous

public void setContinuous(boolean continuous)

setFilterName

public void setFilterName(java.lang.String filterName)

setFilterParams

public void setFilterParams(java.util.Map<java.lang.String,java.lang.Object> filterParams)

setClient

public void setClient(ChangeTrackerClient client)

isActiveOnly

public boolean isActiveOnly()

setActiveOnly

public void setActiveOnly(boolean activeOnly)

getFeed

public java.lang.String getFeed()

getHeartbeatMilliseconds

public long getHeartbeatMilliseconds()

getChangesFeedURL

public java.net.URL getChangesFeedURL()

setAuthenticator

public void setAuthenticator(Authenticator authenticator)

Set Authenticator for BASIC Authentication

run

public void run()

Specified by:

run in interface java.lang.Runnable

runLoop

protected void runLoop()

receivedChange

public boolean receivedChange(java.util.Map<java.lang.String,java.lang.Object> change)

receivedPollResponse

public boolean receivedPollResponse(java.util.Map<java.lang.String,java.lang.Object> response)

setUpstreamError

public void setUpstreamError(java.lang.String message)

start

public boolean start()

stop

public void stop()

setRequestHeaders

public void setRequestHeaders(java.util.Map<java.lang.String,java.lang.Object> requestHeaders)

getLastError

public java.lang.Throwable getLastError()

isRunning

public boolean isRunning()

setDocIDs

public void setDocIDs(java.util.List<java.lang.String> docIDs)

changesFeedPOSTBody

public java.lang.String changesFeedPOSTBody()

changesFeedPOSTBodyMap

public java.util.Map<java.lang.String,java.lang.Object> changesFeedPOSTBodyMap()

setPaused

public void setPaused(boolean paused)

waitIfPaused

protected void waitIfPaused()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object