org.lightcouch

Class Changes

java.lang.Object

org.lightcouch.Changes

public class Changes
extends java.lang.Object

Contains the Change Notifications API, supports change feeds of types normal and continuous.

Usage Example:

 // feed type normal 
 ChangesResult result = dbClient.changes()
        .since("seq-value") // *
        .limit(10)
        .filter("example/filter")
        .getChanges();

 // feed type continuous
 Changes changes = dbClient.changes()
        .includeDocs(true) 
        .heartBeat(30000)
        .continuousChanges(); 
 
 while (changes.hasNext()) { 
        ChangesResult.Row feed = changes.next();
        // changes.stop(); // stop continuous feed
 }
 

* Getting changes since latest update may be obtained by:

 CouchDbInfo dbInfo = dbClient.context().info();
 String since = dbInfo.getUpdateSeq();
 

See Also:

ChangesResult

Method Summary

Modifier and Type	Method and Description
Changes	continuousChanges() Requests Change notifications of feed type continuous.
Changes	filter(java.lang.String filter)
ChangesResult	getChanges() Requests Change notifications of feed type normal.
boolean	hasNext() Checks whether a feed is available in the continuous stream, blocking until a feed is received.
Changes	heartBeat(long heartBeat)
Changes	includeDocs(boolean includeDocs)
Changes	limit(int limit)
ChangesResult.Row	next()
Changes	since(java.lang.String since)
void	stop() Stops a running continuous feed.
Changes	style(java.lang.String style)
Changes	timeout(long timeout)

Methods inherited from class java.lang.Object

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

Method Detail

continuousChanges

public Changes continuousChanges()

Requests Change notifications of feed type continuous.

Feed notifications are accessed in an iterator style.

hasNext

public boolean hasNext()

Checks whether a feed is available in the continuous stream, blocking until a feed is received.

next

public ChangesResult.Row next()

Returns:

The next feed in the stream.

stop

public void stop()

Stops a running continuous feed.

getChanges

public ChangesResult getChanges()

Requests Change notifications of feed type normal.

since

public Changes since(java.lang.String since)

limit

public Changes limit(int limit)

heartBeat

public Changes heartBeat(long heartBeat)

timeout

public Changes timeout(long timeout)

filter

public Changes filter(java.lang.String filter)

includeDocs

public Changes includeDocs(boolean includeDocs)

style

public Changes style(java.lang.String style)