Package org.springframework.data.mongodb.repository

Annotation Interface Tailable

@Retention(RUNTIME)
@Target({METHOD,ANNOTATION_TYPE})
@Documented
public @interface Tailable

Annotation to declare an infinite stream using MongoDB's tailable cursors. An infinite stream can only be used with capped collections. Objects are emitted through the stream as data is inserted into the collection. An infinite stream can only be used with streams that emit more than one element, such as Flux.

The stream may become dead, or invalid, if either the query returns no match or the cursor returns the document at the "end" of the collection and then the application deletes that document.

A stream that is no longer in use must be Disposable.dispose() disposed} otherwise the streams will linger and exhaust resources.

Since:

2.0

Author:

Mark Paluch

See Also:

• Tailable Cursors