org.axonframework.axonserver.connector.query.subscription

Class SubscriptionQueryRequestTarget

java.lang.Object

org.axonframework.axonserver.connector.query.subscription.SubscriptionQueryRequestTarget

public class SubscriptionQueryRequestTarget
extends Object

A listener for Subscription Query requests and response, used by the AxonServerQueryBus to support the AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage, SubscriptionQueryBackpressure, int) functionality.

Since:

4.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
SubscriptionQueryRequestTarget(QueryBus localSegment, Publisher<QueryProviderOutbound> publisher, SubscriptionMessageSerializer serializer) Instantiate a SubscriptionQueryRequestTarget used to receive Subscription Query requests and response.

Method Summary

Modifier and Type	Method and Description
void	onApplicationDisconnected(String context) Cancels all the subscription query Registrations for the given context which are contained by this SubscriptionQueryRequestTarget.
void	onSubscriptionQueryRequest(String context, QueryProviderInbound queryProviderInbound) Decides, based on the wrapped SubscriptionQueryRequest returned from the given QueryProviderInbound, what operation to perform.

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriptionQueryRequestTarget

public SubscriptionQueryRequestTarget(QueryBus localSegment,
                                      Publisher<QueryProviderOutbound> publisher,
                                      SubscriptionMessageSerializer serializer)

Instantiate a SubscriptionQueryRequestTarget used to receive Subscription Query requests and response.

Parameters:

localSegment - a QueryBus used to subscribe incoming Subscription Query Requests to the local instance

publisher - a Publisher of type QueryProviderOutbound to send the initial result and the subsequent updates on

serializer - a SubscriptionMessageSerializer used to convert the Axon Server gRPC based messages into Axon Framework based Query messages and vice versa

Method Detail

onSubscriptionQueryRequest

public void onSubscriptionQueryRequest(String context,
                                       QueryProviderInbound queryProviderInbound)

Decides, based on the wrapped SubscriptionQueryRequest returned from the given QueryProviderInbound, what operation to perform. Can switch between subscribing in general, retrieving the initial result and unsubscribing from future results.

Parameters:

context - defines the (Bounded) Context within which the given subscription query request should be performed in

queryProviderInbound - a QueryProviderInbound from which the SubscriptionQueryRequest will be retrieved to perform a follow up operation with

onApplicationDisconnected

public void onApplicationDisconnected(String context)

Cancels all the subscription query Registrations for the given context which are contained by this SubscriptionQueryRequestTarget.

Parameters:

context - defines the (Bounded) Context for which the subscription query Registrations should be canceled