MessageListenerContainer (Spring Data MongoDB 2.1.0.RELEASE API)

Field Summary
- Fields inherited from interface org.springframework.context.SmartLifecycle
  DEFAULT_PHASE

All Methods Static Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`static MessageListenerContainer`	`create(MongoTemplate template)` Create a new `MessageListenerContainer` given `MongoTemplate`.
`Optional<Subscription>`	`lookup(SubscriptionRequest<?,?,?> request)` Lookup the given `SubscriptionRequest` within the container and return the associated `Subscription` if present.
`<S,T> Subscription`	`register(SubscriptionRequest<S,? super T,? extends SubscriptionRequest.RequestOptions> request, Class<T> bodyType)` Register a new `SubscriptionRequest` in the container.
`<S,T> Subscription`	`register(SubscriptionRequest<S,? super T,? extends SubscriptionRequest.RequestOptions> request, Class<T> bodyType, ErrorHandler errorHandler)` Register a new `SubscriptionRequest` in the container.
`default <T> Subscription`	`register(SubscriptionRequest<T,Object,? extends SubscriptionRequest.RequestOptions> request)` Register a new `SubscriptionRequest` in the container.
`void`	`remove(Subscription subscription)` Unregister a given `Subscription` from the container.

Methods inherited from interface org.springframework.context.SmartLifecycle
getPhase, isAutoStartup, stop

Methods inherited from interface org.springframework.context.Lifecycle
isRunning, start, stop

default <T> Subscription register(SubscriptionRequest<T,Object,? extends SubscriptionRequest.RequestOptions> request)

is
already running

the Subscription will be added and run immediately, otherwise it'll be scheduled and started once the container is actually started.

 
     MessageListenerContainer container = ...

     MessageListener, Object> messageListener = (message) -> message....
     ChangeStreamRequest

Interface MessageListenerContainer