Package com.couchbase.lite
Class AbstractReplicator
java.lang.Object
com.couchbase.lite.internal.replicator.BaseReplicator
com.couchbase.lite.AbstractReplicator
- All Implemented Interfaces:
com.couchbase.lite.internal.Listenable<ReplicatorChange,
,ReplicatorChangeListener> AutoCloseable
- Direct Known Subclasses:
Replicator
public abstract class AbstractReplicator
extends com.couchbase.lite.internal.replicator.BaseReplicator
implements com.couchbase.lite.internal.Listenable<ReplicatorChange,ReplicatorChangeListener>
A replicator for replicating document changes between a local database and a target database.
The replicator can be bidirectional or either push or pull. The replicator can also be one-shot
or continuous. The replicator runs asynchronously, so observe the status to
be notified of progress.
-
Method Summary
Modifier and TypeMethodDescriptionaddChangeListener
(ReplicatorChangeListener listener) Adds a change listener for the changes in the replication status and progress.addChangeListener
(Executor executor, ReplicatorChangeListener listener) Adds a change listener for the changes in the replication status and progress with an executor on which the changes will be posted to the listener.Adds a listener for receiving the replication status of the specified document.addDocumentReplicationListener
(Executor executor, DocumentReplicationListener listener) Adds a listener for receiving the replication status of the specified document with an executor on which the status will be posted to the listener.void
close()
The replicator's configuration.Deprecated.Use getPendingDocumentIds(Collection)getPendingDocumentIds
(Collection collection) Get a best effort list of documents in the passed collection that are still pending replication.The server certificates received from the server during the TLS handshake.The replicator's current status: its activity level and progress.boolean
isDocumentPending
(String docId) Deprecated.Use isDocumentPending(String, Collection)boolean
isDocumentPending
(String docId, Collection collection) Best effort check to see if the document whose ID is passed is still pending replication.void
Deprecated.use ListenerToken.removevoid
start()
Start the replicator.void
start
(boolean resetCheckpoint) Start the replicator.void
stop()
Stop a running replicator.toString()
Methods inherited from class com.couchbase.lite.internal.replicator.BaseReplicator
getC4Replicator
-
Method Details
-
start
public void start()Start the replicator. -
start
public void start(boolean resetCheckpoint) Start the replicator. This method does not wait for the replicator to start. The replicator runs asynchronously and reports its progress through replicator change notifications. -
stop
public void stop()Stop a running replicator. This method does not wait for the replicator to stop. When the replicator actually stops, it will a broadcast a new state, STOPPED, to change listeners. -
getConfig
The replicator's configuration.- Returns:
- this replicator's configuration
-
getStatus
The replicator's current status: its activity level and progress.- Returns:
- this replicator's status
-
getServerCertificates
The server certificates received from the server during the TLS handshake.- Returns:
- this replicator's server certificates.
-
getPendingDocumentIds
Deprecated.Use getPendingDocumentIds(Collection)Get a best effort list of documents in the default collection, that are still pending replication.- Returns:
- a set of ids for documents in the default collection still awaiting replication.
- Throws:
CouchbaseLiteException
-
getPendingDocumentIds
@NonNull public Set<String> getPendingDocumentIds(@NonNull Collection collection) throws CouchbaseLiteException Get a best effort list of documents in the passed collection that are still pending replication.- Returns:
- a set of ids for documents in the passed collection still awaiting replication.
- Throws:
CouchbaseLiteException
-
isDocumentPending
Deprecated.Use isDocumentPending(String, Collection)Best effort check to see if the document whose ID is passed is still pending replication.- Parameters:
docId
- Document id- Returns:
- true if the document is pending
- Throws:
CouchbaseLiteException
-
isDocumentPending
public boolean isDocumentPending(@NonNull String docId, @NonNull Collection collection) throws CouchbaseLiteException Best effort check to see if the document whose ID is passed is still pending replication.- Parameters:
docId
- Document id- Returns:
- true if the document is pending
- Throws:
CouchbaseLiteException
-
addChangeListener
Adds a change listener for the changes in the replication status and progress.The changes will be delivered on the UI thread for the Android platform On other Java platforms, the callback will occur on the single threaded default executor.
When developing a Java Desktop application using Swing or JavaFX that needs to update the UI after receiving the changes, make sure to schedule the UI update on the UI thread by using SwingUtilities.invokeLater(Runnable) or Platform.runLater(Runnable) respectively.
- Specified by:
addChangeListener
in interfacecom.couchbase.lite.internal.Listenable<ReplicatorChange,
ReplicatorChangeListener> - Parameters:
listener
- callback
-
addChangeListener
@NonNull public ListenerToken addChangeListener(@Nullable Executor executor, @NonNull ReplicatorChangeListener listener) Adds a change listener for the changes in the replication status and progress with an executor on which the changes will be posted to the listener. If the executor is not specified, the changes will be delivered on the UI thread on Android platform and on the single threaded default executor on other Java platforms- Specified by:
addChangeListener
in interfacecom.couchbase.lite.internal.Listenable<ReplicatorChange,
ReplicatorChangeListener> - Parameters:
executor
- executor on which events will be deliveredlistener
- callback
-
addDocumentReplicationListener
@NonNull public ListenerToken addDocumentReplicationListener(@NonNull DocumentReplicationListener listener) Adds a listener for receiving the replication status of the specified document. The status will be delivered on the UI thread for the Android platform and on the single threaded default executor on other platforms.When developing a Java Desktop application using Swing or JavaFX that needs to update the UI after receiving the status, make sure to schedule the UI update on the UI thread by using SwingUtilities.invokeLater(Runnable) or Platform.runLater(Runnable) respectively.
- Parameters:
listener
- callback- Returns:
- A ListenerToken that can be used to remove the handler in the future.
-
addDocumentReplicationListener
@NonNull public ListenerToken addDocumentReplicationListener(@Nullable Executor executor, @NonNull DocumentReplicationListener listener) Adds a listener for receiving the replication status of the specified document with an executor on which the status will be posted to the listener. If the executor is not specified, the status will be delivered on the UI thread for the Android platform and on an arbitrary thread for the Java platform.- Parameters:
executor
- executor on which events will be deliveredlistener
- callback
-
removeChangeListener
Deprecated.use ListenerToken.removeRemove the given ReplicatorChangeListener or DocumentReplicationListener from the this replicator.- Parameters:
token
- returned by a previous call to addChangeListener or addDocumentListener.
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Overrides:
close
in classcom.couchbase.lite.internal.replicator.BaseReplicator
-
toString
-