public static class ChangeStreamRequest.ChangeStreamRequestOptions extends Object implements SubscriptionRequest.RequestOptions
SubscriptionRequest.RequestOptions
implementation specific to a ChangeStreamRequest
.Constructor and Description |
---|
ChangeStreamRequestOptions(String databaseName,
String collectionName,
ChangeStreamOptions options)
Create new
ChangeStreamRequest.ChangeStreamRequestOptions . |
ChangeStreamRequestOptions(String databaseName,
String collectionName,
Duration maxAwaitTime,
ChangeStreamOptions options)
Create new
ChangeStreamRequest.ChangeStreamRequestOptions . |
Modifier and Type | Method and Description |
---|---|
ChangeStreamOptions |
getChangeStreamOptions()
Get the
ChangeStreamOptions defined. |
String |
getCollectionName()
Get the collection name.
|
String |
getDatabaseName()
Get the database name of the db.
|
Duration |
maxAwaitTime()
Get the maximum wait time (the time till the next Document is emitted) to apply when reading from the collection.
|
static ChangeStreamRequest.ChangeStreamRequestOptions |
of(SubscriptionRequest.RequestOptions options) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
justCollection, justDatabase, none, of
public ChangeStreamRequestOptions(@Nullable String databaseName, @Nullable String collectionName, ChangeStreamOptions options)
ChangeStreamRequest.ChangeStreamRequestOptions
.databaseName
- can be null.collectionName
- can be null.options
- must not be null.public ChangeStreamRequestOptions(@Nullable String databaseName, @Nullable String collectionName, @Nullable Duration maxAwaitTime, ChangeStreamOptions options)
ChangeStreamRequest.ChangeStreamRequestOptions
.databaseName
- can be null.collectionName
- can be null.maxAwaitTime
- can be null.options
- must not be null.public static ChangeStreamRequest.ChangeStreamRequestOptions of(SubscriptionRequest.RequestOptions options)
public ChangeStreamOptions getChangeStreamOptions()
ChangeStreamOptions
defined.public String getCollectionName()
SubscriptionRequest.RequestOptions
getCollectionName
in interface SubscriptionRequest.RequestOptions
public String getDatabaseName()
SubscriptionRequest.RequestOptions
getDatabaseName
in interface SubscriptionRequest.RequestOptions
database
is used.public Duration maxAwaitTime()
SubscriptionRequest.RequestOptions
maxAwaitTime
in interface SubscriptionRequest.RequestOptions
Duration.ZERO
by default.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.