Package org.springframework.data.mongodb

Class SessionAwareMethodInterceptor<D,C>

java.lang.Object

org.springframework.data.mongodb.SessionAwareMethodInterceptor<D,C>

Type Parameters:

D - Type of the actual Mongo Database.

C - Type of the actual Mongo Collection.

All Implemented Interfaces:

Advice, Interceptor, MethodInterceptor

public class SessionAwareMethodInterceptor<D,C>
extends Object
implements MethodInterceptor

MethodInterceptor implementation looking up and invoking an alternative target method having ClientSession as its first argument. This allows seamless integration with the existing code base.
The MethodInterceptor is aware of methods on MongoCollection that my return new instances of itself like (eg. MongoCollection.withWriteConcern(WriteConcern) and decorate them if not already proxied.

Since:

2.1

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SessionAwareMethodInterceptor.ClientSessionOperator<T>	Represents an operation upon two operands of the same type, producing a result of the same type as the operands accepting ClientSession.

Constructor Summary

Constructors

Constructor	Description
SessionAwareMethodInterceptor(com.mongodb.session.ClientSession session, T target, Class<? extends com.mongodb.session.ClientSession> sessionType, Class<D> databaseType, SessionAwareMethodInterceptor.ClientSessionOperator<D> databaseDecorator, Class<C> collectionType, SessionAwareMethodInterceptor.ClientSessionOperator<C> collectionDecorator)	Create a new SessionAwareMethodInterceptor for given target.

Method Summary

Modifier and Type	Method	Description
protected Object	decorate(Object target)
Object	invoke(MethodInvocation methodInvocation)

Methods inherited from class java.lang.Object

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

Constructor Details

SessionAwareMethodInterceptor

public SessionAwareMethodInterceptor(com.mongodb.session.ClientSession session,
 T target,
 Class<? extends com.mongodb.session.ClientSession> sessionType,
 Class<D> databaseType,
 SessionAwareMethodInterceptor.ClientSessionOperator<D> databaseDecorator,
 Class<C> collectionType,
 SessionAwareMethodInterceptor.ClientSessionOperator<C> collectionDecorator)

Create a new SessionAwareMethodInterceptor for given target.

Type Parameters:

T - target object type.

Parameters:

session - the ClientSession to be used on invocation.

target - the original target object.

databaseType - the MongoDB database type

databaseDecorator - a SessionAwareMethodInterceptor.ClientSessionOperator used to create the proxy for an imperative / reactive MongoDatabase.

collectionType - the MongoDB collection type.

collectionDecorator - a SessionAwareMethodInterceptor.ClientSessionOperator used to create the proxy for an imperative / reactive MongoCollection.

Method Details

invoke

@Nullable
public Object invoke(MethodInvocation methodInvocation)
              throws Throwable

Specified by:

invoke in interface MethodInterceptor

Throws:

Throwable

decorate

protected Object decorate(Object target)