Package | Description |
---|---|
org.springframework.data.mongodb.core.messaging |
MongoDB specific messaging support for listening to eg.
|
Modifier and Type | Method and Description |
---|---|
MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> |
ChangeStreamRequest.getMessageListener() |
MessageListener<org.bson.Document,? super T> |
TailableCursorRequest.getMessageListener() |
MessageListener<S,? super T> |
SubscriptionRequest.getMessageListener()
Obtain the
MessageListener to publish messages to. |
Modifier and Type | Method and Description |
---|---|
static <T> ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.builder(MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> listener)
Obtain a shiny new
ChangeStreamRequest.ChangeStreamRequestBuilder and start defining your ChangeStreamRequest in this
fancy fluent way. |
static <T> TailableCursorRequest.TailableCursorRequestBuilder<T> |
TailableCursorRequest.builder(MessageListener<org.bson.Document,? super T> listener)
Obtain a shiny new
TailableCursorRequest.TailableCursorRequestBuilder and start defining options in this fancy fluent way. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.publishTo(MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> messageListener)
Set the
MessageListener event messages will be published to. |
TailableCursorRequest.TailableCursorRequestBuilder<T> |
TailableCursorRequest.TailableCursorRequestBuilder.publishTo(MessageListener<org.bson.Document,? super T> messageListener)
Set the
MessageListener event messages will be published to. |
Constructor and Description |
---|
ChangeStreamRequest(MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> messageListener,
SubscriptionRequest.RequestOptions options)
|
TailableCursorRequest(MessageListener<org.bson.Document,? super T> messageListener,
SubscriptionRequest.RequestOptions options)
|
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.