org.axonframework.axonserver.connector.util

Class ProcessingInstructionHelper

java.lang.Object

org.axonframework.axonserver.connector.util.ProcessingInstructionHelper

public abstract class ProcessingInstructionHelper
extends Object

Utility class contain helper methods to extract information from ProcessingInstructions.

Since:

4.0

Author:

Marc Gathier

Method Summary

Modifier and Type	Method and Description
static boolean	axonServerSupportsQueryStreaming(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions) Retrieve whether Axon Server supports streaming from the given processingInstructions, by searching for the value of ProcessingKey.SERVER_SUPPORTS_STREAMING.
static boolean	clientSupportsQueryStreaming(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions) Retrieve whether Client (query issuer) supports streaming from the given processingInstructions, by searching for the value of ProcessingKey.CLIENT_SUPPORTS_STREAMING.
static long	numberOfResults(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions) Retrieve the desired 'number of results' as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.NR_OF_RESULTS.
static long	priority(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions) Retrieve the priority as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.PRIORITY.
static long	timeout(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions) Retrieve the desired 'number of results' as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.NR_OF_RESULTS.

Methods inherited from class java.lang.Object

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

Method Detail

priority

public static long priority(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)

Retrieve the priority as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.PRIORITY.

Parameters:

processingInstructions - a List of ProcessingInstructions to retrieve the ProcessingKey.PRIORITY from

Returns:

a long specifying the priority of a given operation

numberOfResults

public static long numberOfResults(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)

Retrieve the desired 'number of results' as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.NR_OF_RESULTS.

Parameters:

processingInstructions - a List of ProcessingInstructions to retrieve the ProcessingKey.NR_OF_RESULTS from

Returns:

a long specifying the desired 'number of results' for a given operation

axonServerSupportsQueryStreaming

public static boolean axonServerSupportsQueryStreaming(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)

Retrieve whether Axon Server supports streaming from the given processingInstructions, by searching for the value of ProcessingKey.SERVER_SUPPORTS_STREAMING.

Parameters:

processingInstructions - a List of ProcessingInstructions to retrieve the ProcessingKey.SERVER_SUPPORTS_STREAMING from

Returns:

true if Axon Server supports streaming, false otherwise

clientSupportsQueryStreaming

public static boolean clientSupportsQueryStreaming(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)

Retrieve whether Client (query issuer) supports streaming from the given processingInstructions, by searching for the value of ProcessingKey.CLIENT_SUPPORTS_STREAMING.

Parameters:

processingInstructions - a List of ProcessingInstructions to retrieve the ProcessingKey.CLIENT_SUPPORTS_STREAMING from

Returns:

true if Client supports streaming, false otherwise

timeout

public static long timeout(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)

Retrieve the desired 'number of results' as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.NR_OF_RESULTS.

Parameters:

processingInstructions - a List of ProcessingInstructions to retrieve the ProcessingKey.NR_OF_RESULTS from

Returns:

a long specifying the desired 'number of results' for a given operation