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, Runnable completeHandler) Constructs a UpdateHandlerRegistration with given registration and updates.

Method Summary

Modifier and Type	Method and Description
void	complete() Completes the getUpdates() Flux.
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,
                                 Runnable completeHandler)

Constructs a UpdateHandlerRegistration with given registration and updates.

Parameters:

registration - used to cancel the registration

updates - used to subscribe to updates stream

completeHandler - handler invoked on complete()

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

complete

public void complete()

Completes the getUpdates() Flux. The consumer can use this method to indicate it is no longer interested in updates. This operation automatically closes the registration too.