@FunctionalInterface
public interface MessageCollectionCallback<T>
extends org.springframework.data.mongodb.core.CollectionCallback<T>
MongoDbOutboundGateway
as an alternative to other query options on the gateway.
Plays the same role as standard CollectionCallback
,
but with Message<?> requestMessage
context during handleMessage()
process in the MongoDbOutboundGateway
.
CollectionCallback
Modifier and Type | Method and Description |
---|---|
default T |
doInCollection(com.mongodb.client.MongoCollection<org.bson.Document> collection) |
T |
doInCollection(com.mongodb.client.MongoCollection<org.bson.Document> collection,
org.springframework.messaging.Message<?> requestMessage)
Perform a Mongo operation in the collection using request message as a context.
|
@Nullable T doInCollection(com.mongodb.client.MongoCollection<org.bson.Document> collection, org.springframework.messaging.Message<?> requestMessage) throws com.mongodb.MongoException, org.springframework.dao.DataAccessException
collection
- never null.requestMessage
- the request message ot use for operationscom.mongodb.MongoException
- the MongoDB-specific exceptionorg.springframework.dao.DataAccessException
- the data access exceptiondefault T doInCollection(com.mongodb.client.MongoCollection<org.bson.Document> collection) throws com.mongodb.MongoException, org.springframework.dao.DataAccessException
doInCollection
in interface org.springframework.data.mongodb.core.CollectionCallback<T>
com.mongodb.MongoException
org.springframework.dao.DataAccessException