public class RemoteDatabaseChanges extends RemoteChangesClientBase<IDatabaseChanges,DatabaseConnectionState> implements IDatabaseChanges
Modifier and Type | Field and Description |
---|---|
protected DocumentConvention |
conventions |
protected boolean |
watchAllDocs |
protected boolean |
watchAllIndexes |
protected boolean |
watchAllTransformers |
protected java.util.concurrent.ConcurrentSkipListSet<java.lang.String> |
watchedBulkInserts |
protected java.util.concurrent.ConcurrentSkipListSet<java.lang.String> |
watchedCollections |
protected java.util.concurrent.ConcurrentSkipListSet<java.lang.String> |
watchedDocs |
protected java.util.concurrent.ConcurrentSkipListSet<java.lang.String> |
watchedIndexes |
protected java.util.concurrent.ConcurrentSkipListSet<java.lang.String> |
watchedPrefixes |
protected java.util.concurrent.ConcurrentSkipListSet<java.lang.String> |
watchedTypes |
counters, logger
Constructor and Description |
---|
RemoteDatabaseChanges(java.lang.String url,
java.lang.String apiKey,
HttpJsonRequestFactory jsonRequestFactory,
DocumentConvention conventions,
IDocumentStoreReplicationInformer replicationInformer,
Action0 onDispose,
Function4<java.lang.String,Etag,java.lang.String[],OperationMetadata,java.lang.Boolean> tryResolveConflictByUsingRegisteredConflictListeners) |
addConnectionStatusChanged, clientSideHeartbeat, close, establishConnection, isConnected, logOnConnectionStatusChanged, onCompleted, onError, onNext, removeConnectionStatusChanges, send
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addConnectionStatusChanged, isConnected, removeConnectionStatusChanges
protected final java.util.concurrent.ConcurrentSkipListSet<java.lang.String> watchedDocs
protected final java.util.concurrent.ConcurrentSkipListSet<java.lang.String> watchedPrefixes
protected final java.util.concurrent.ConcurrentSkipListSet<java.lang.String> watchedTypes
protected final java.util.concurrent.ConcurrentSkipListSet<java.lang.String> watchedCollections
protected final java.util.concurrent.ConcurrentSkipListSet<java.lang.String> watchedIndexes
protected final java.util.concurrent.ConcurrentSkipListSet<java.lang.String> watchedBulkInserts
protected boolean watchAllDocs
protected boolean watchAllIndexes
protected boolean watchAllTransformers
protected DocumentConvention conventions
public RemoteDatabaseChanges(java.lang.String url, java.lang.String apiKey, HttpJsonRequestFactory jsonRequestFactory, DocumentConvention conventions, IDocumentStoreReplicationInformer replicationInformer, Action0 onDispose, Function4<java.lang.String,Etag,java.lang.String[],OperationMetadata,java.lang.Boolean> tryResolveConflictByUsingRegisteredConflictListeners)
protected void subscribeOnServer()
subscribeOnServer
in class RemoteChangesClientBase<IDatabaseChanges,DatabaseConnectionState>
protected void notifySubscribers(java.lang.String type, RavenJObject value, AtomicDictionary<DatabaseConnectionState> counters)
notifySubscribers
in class RemoteChangesClientBase<IDatabaseChanges,DatabaseConnectionState>
public IObservable<IndexChangeNotification> forIndex(java.lang.String indexName)
forIndex
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocument(java.lang.String docId)
forDocument
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forAllDocuments()
forAllDocuments
in interface IDatabaseChanges
public IObservable<BulkInsertChangeNotification> forBulkInsert(java.util.UUID operationId)
forBulkInsert
in interface IDatabaseChanges
public IObservable<IndexChangeNotification> forAllIndexes()
forAllIndexes
in interface IDatabaseChanges
public IObservable<TransformerChangeNotification> forAllTransformers()
forAllTransformers
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsStartingWith(java.lang.String docIdPrefix)
forDocumentsStartingWith
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsInCollection(java.lang.String collectionName)
forDocumentsInCollection
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsInCollection(java.lang.Class<?> clazz)
forDocumentsInCollection
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsOfType(java.lang.String typeName)
forDocumentsOfType
in interface IDatabaseChanges
public IObservable<DocumentChangeNotification> forDocumentsOfType(java.lang.Class<?> clazz)
forDocumentsOfType
in interface IDatabaseChanges
public IObservable<ReplicationConflictNotification> forAllReplicationConflicts()
forAllReplicationConflicts
in interface IDatabaseChanges
public void waitForAllPendingSubscriptions()
waitForAllPendingSubscriptions
in interface IConnectableChanges
Copyright © 2014. All Rights Reserved.