Package com.alpha.mongodb.sharding.core.template

Class ShardedReactiveMongoTemplate

java.lang.Object

org.springframework.data.mongodb.core.ReactiveMongoTemplate

com.alpha.mongodb.sharding.core.template.ShardedReactiveMongoTemplate

All Implemented Interfaces:

ShardingAssistant, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.data.mongodb.core.ReactiveAggregationOperation, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation, org.springframework.data.mongodb.core.ReactiveFindOperation, org.springframework.data.mongodb.core.ReactiveFluentMongoOperations, org.springframework.data.mongodb.core.ReactiveInsertOperation, org.springframework.data.mongodb.core.ReactiveMapReduceOperation, org.springframework.data.mongodb.core.ReactiveMongoOperations, org.springframework.data.mongodb.core.ReactiveRemoveOperation, org.springframework.data.mongodb.core.ReactiveUpdateOperation

Direct Known Subclasses:

CollectionShardedReactiveMongoTemplate, DatabaseShardedReactiveMongoTemplate

public abstract class ShardedReactiveMongoTemplate
extends org.springframework.data.mongodb.core.ReactiveMongoTemplate
implements ShardingAssistant

Abstract Base Sharded Reactive Mongo Template

Author:

Shashank Sharma

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveAggregationOperation

org.springframework.data.mongodb.core.ReactiveAggregationOperation.AggregationOperationWithAggregation<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.AggregationOperationWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.ReactiveAggregation<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.TerminatingAggregationOperation<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveChangeStreamOperation

org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ReactiveChangeStream<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ResumingChangeStream<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.TerminatingChangeStream<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveFindOperation

org.springframework.data.mongodb.core.ReactiveFindOperation.DistinctWithProjection, org.springframework.data.mongodb.core.ReactiveFindOperation.DistinctWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindDistinct, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.ReactiveFind<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingDistinct<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingFind<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingFindNear<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveInsertOperation

org.springframework.data.mongodb.core.ReactiveInsertOperation.InsertWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveInsertOperation.ReactiveInsert<T extends Object>, org.springframework.data.mongodb.core.ReactiveInsertOperation.TerminatingInsert<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveMapReduceOperation

org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithMapFunction<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithReduceFunction<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.ReactiveMapReduce<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.TerminatingMapReduce<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveRemoveOperation

org.springframework.data.mongodb.core.ReactiveRemoveOperation.ReactiveRemove<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.RemoveWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.RemoveWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.TerminatingRemove<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveUpdateOperation

org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndModifyWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndReplaceWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndReplaceWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.ReactiveUpdate<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingFindAndModify<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingFindAndReplace<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingUpdate<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithUpdate<T extends Object>

Field Summary

Fields inherited from class org.springframework.data.mongodb.core.ReactiveMongoTemplate

NO_OP_REF_RESOLVER

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ShardedReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient mongoClient, String databaseName, ShardingOptions shardingOptions)
protected	ShardedReactiveMongoTemplate(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory, ShardingOptions shardingOptions)
protected	ShardedReactiveMongoTemplate(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory, org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter, ShardingOptions shardingOptions)
protected	ShardedReactiveMongoTemplate(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDatabaseFactory, org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter, Consumer<Throwable> subscriptionExceptionHandler, ShardingOptions shardingOptions)

Method Summary

Modifier and Type	Method	Description
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Methods inherited from class org.springframework.data.mongodb.core.ReactiveMongoTemplate

aggregate, aggregate, aggregate, aggregate, aggregateAndReturn, changeStream, changeStream, collectionExists, collectionExists, convertToCreateCollectionOptions, convertToCreateCollectionOptions, count, count, count, countCanBeEstimated, createCollection, createCollection, createCollection, createCollection, createFlux, createFlux, createMono, createMono, doAggregate, doCount, doCreateCollection, doEstimatedCount, doExactCount, doFind, doFind, doFind, doFindAndDelete, doFindAndModify, doFindAndRemove, doFindAndReplace, doFindOne, doFindOne, doGetDatabase, doInsert, doInsertAll, doInsertBatch, doRemove, doSave, doUpdate, dropCollection, dropCollection, ensureNotCollectionLike, ensureNotIterable, estimatedCount, exactCount, execute, execute, execute, executeCommand, executeCommand, executeCommand, exists, exists, exists, find, find, findAll, findAll, findAllAndRemove, findAllAndRemove, findAllAndRemove, findAndModify, findAndModify, findAndModify, findAndModify, findAndRemove, findAndRemove, findAndReplace, findById, findById, findDistinct, findDistinct, findOne, findOne, geoNear, geoNear, geoNear, getCollection, getCollectionName, getCollectionNames, getConverter, getMongoDatabase, getMongoDatabaseFactory, indexOps, indexOps, insert, insert, insert, insert, insert, insert, insertAll, insertAll, insertAll, insertAll, insertDocument, insertDocumentList, inTransaction, inTransaction, mapReduce, mapReduce, mapReduce, maybeCallAfterConvert, maybeCallAfterSave, maybeCallBeforeConvert, maybeCallBeforeSave, maybeEmitEvent, prepareCollection, prepareDatabase, prepareWriteConcern, query, remove, remove, remove, remove, remove, remove, remove, remove, save, save, save, save, saveDocument, setEntityCallbacks, setReadPreference, setSessionSynchronization, setWriteConcern, setWriteConcernResolver, setWriteResultChecking, tail, tail, update, updateFirst, updateFirst, updateFirst, updateMulti, updateMulti, updateMulti, upsert, upsert, upsert, useEstimatedCount, withSession, withSession, withSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.data.mongodb.core.ReactiveMongoOperations

changeStream, changeStream, estimatedCount, exactCount, exactCount, findAndReplace, findAndReplace, findAndReplace, findAndReplace, findAndReplace, findAndReplace, findDistinct, findDistinct, withSession

Methods inherited from interface com.alpha.mongodb.sharding.core.assitant.ShardingAssistant

getHintResolutionCallbacks, getShardingOptions, resolveCollectionHintWithoutEntityContext, resolveCollectionNameWithoutEntityContext, resolveDatabaseHintWithoutEntityContext, resolveDatabaseNameWithoutEntityContext

Constructor Detail

ShardedReactiveMongoTemplate

protected ShardedReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient mongoClient,
                                       String databaseName,
                                       ShardingOptions shardingOptions)

ShardedReactiveMongoTemplate

protected ShardedReactiveMongoTemplate(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory,
                                       ShardingOptions shardingOptions)

ShardedReactiveMongoTemplate

protected ShardedReactiveMongoTemplate(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory,
                                       org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter,
                                       ShardingOptions shardingOptions)

ShardedReactiveMongoTemplate

protected ShardedReactiveMongoTemplate(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDatabaseFactory,
                                       org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter,
                                       Consumer<Throwable> subscriptionExceptionHandler,
                                       ShardingOptions shardingOptions)

Method Detail

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Overrides:

setApplicationContext in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

Throws:

org.springframework.beans.BeansException