org.axonframework.queryhandling

Class UpdateHandlerRegistration<U>

java.lang.Object

org.axonframework.queryhandling.UpdateHandlerRegistration<U>

public class UpdateHandlerRegistration<U>
extends Object

Result of registering an Update Handler. Contains a Flux with updates and Registration to be cancelled when we're no longer interested in updates.

Since:

4.0

Author:

Milan Savic

Constructor Summary

Constructors

Constructor and Description
UpdateHandlerRegistration(Registration registration, reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates) Constructs a UpdateHandlerRegistration with given registration and updates.

Method Summary

Modifier and Type	Method and Description
Registration	getRegistration() Gets the registration.
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>>	getUpdates() Gets the updates.

Methods inherited from class java.lang.Object

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

Constructor Detail

UpdateHandlerRegistration

public UpdateHandlerRegistration(Registration registration,
                                 reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates)

Constructs a UpdateHandlerRegistration with given registration and updates.

Parameters:

registration - used to cancel the registration

updates - used to subscribe to updates stream

Method Detail

getRegistration

public Registration getRegistration()

Gets the registration.

Returns:

the registration used for cancellation of updates

getUpdates

public reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> getUpdates()

Gets the updates.

Returns:

a Flux for subscribing to the update stream