Package org.axonframework.axonserver.connector.query.subscription

Class DeserializedResult<I,U>

java.lang.Object

org.axonframework.axonserver.connector.query.subscription.DeserializedResult<I,U>

Type Parameters:

I - a generic specifying the type of the initial result of the SubscriptionQueryResult

U - a generic specifying the type of the subsequent updates of the SubscriptionQueryResult

All Implemented Interfaces:

AutoCloseable, org.axonframework.common.Registration, org.axonframework.queryhandling.SubscriptionQueryResult<org.axonframework.queryhandling.QueryResponseMessage<I>,org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>>

@Deprecated
public class DeserializedResult<I,U>
extends Object
implements org.axonframework.queryhandling.SubscriptionQueryResult<org.axonframework.queryhandling.QueryResponseMessage<I>,org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>>

Deprecated.

in through use of the AxonServer java connector

A decorator of the SubscriptionQueryUpdateMessage to deserialize a QueryResponseMessage and QueryUpdate messages.

Since:

4.0

Author:

Sara Pellegrini

Field Summary

Fields inherited from interface org.axonframework.queryhandling.SubscriptionQueryResult

logger

Constructor Summary

Constructors

Constructor	Description
DeserializedResult(org.axonframework.queryhandling.SubscriptionQueryResult<io.axoniq.axonserver.grpc.query.QueryResponse,io.axoniq.axonserver.grpc.query.QueryUpdate> delegate, SubscriptionMessageSerializer serializer)	Deprecated. Instantiate a DeserializedResult wrapping the delegate which will be serialized by the given serializer.

Method Summary

Modifier and Type	Method	Description
boolean	cancel()	Deprecated.
reactor.core.publisher.Mono<org.axonframework.queryhandling.QueryResponseMessage<I>>	initialResult()	Deprecated.
reactor.core.publisher.Flux<org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>>	updates()	Deprecated.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.common.Registration

close

Methods inherited from interface org.axonframework.queryhandling.SubscriptionQueryResult

handle, handle

Constructor Details

DeserializedResult

public DeserializedResult(org.axonframework.queryhandling.SubscriptionQueryResult<io.axoniq.axonserver.grpc.query.QueryResponse,io.axoniq.axonserver.grpc.query.QueryUpdate> delegate,
 SubscriptionMessageSerializer serializer)

Deprecated.

Instantiate a DeserializedResult wrapping the delegate which will be serialized by the given serializer.

Parameters:

delegate - a SubscriptionQueryResult which will be wrapped

serializer - a SubscriptionMessageSerializer used to serialize the initial results and the subsequent updates

Method Details

initialResult

public reactor.core.publisher.Mono<org.axonframework.queryhandling.QueryResponseMessage<I>> initialResult()

Deprecated.

Specified by:

initialResult in interface org.axonframework.queryhandling.SubscriptionQueryResult<I,U>

updates

public reactor.core.publisher.Flux<org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>> updates()

Deprecated.

Specified by:

updates in interface org.axonframework.queryhandling.SubscriptionQueryResult<I,U>

cancel

public boolean cancel()

Deprecated.

Specified by:

cancel in interface org.axonframework.common.Registration