public abstract class ProcessingInstructionHelper extends Object
ProcessingInstruction
s.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 . |
public static long priority(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)
long
from the given processingInstructions
, by searching for the
ProcessingInstruction
who's key equals the ProcessingKey.PRIORITY
.processingInstructions
- a List
of ProcessingInstruction
s to retrieve the ProcessingKey.PRIORITY
fromlong
specifying the priority of a given operationpublic static long numberOfResults(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)
long
from the given processingInstructions
, by
searching for the ProcessingInstruction
who's key equals the ProcessingKey.NR_OF_RESULTS
.processingInstructions
- a List
of ProcessingInstruction
s to retrieve the ProcessingKey.NR_OF_RESULTS
fromlong
specifying the desired 'number of results' for a given operationpublic static boolean axonServerSupportsQueryStreaming(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)
processingInstructions
, by
searching for the value of ProcessingKey.SERVER_SUPPORTS_STREAMING
.processingInstructions
- a List
of ProcessingInstruction
s to retrieve the ProcessingKey.SERVER_SUPPORTS_STREAMING
fromtrue
if Axon Server supports streaming, false
otherwisepublic static boolean clientSupportsQueryStreaming(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)
processingInstructions
, by searching for the value of ProcessingKey.CLIENT_SUPPORTS_STREAMING
.processingInstructions
- a List
of ProcessingInstruction
s to retrieve the ProcessingKey.CLIENT_SUPPORTS_STREAMING
fromtrue
if Client supports streaming, false
otherwisepublic static long timeout(List<io.axoniq.axonserver.grpc.ProcessingInstruction> processingInstructions)
long
from the given processingInstructions
, by
searching for the ProcessingInstruction
who's key equals the ProcessingKey.NR_OF_RESULTS
.processingInstructions
- a List
of ProcessingInstruction
s to retrieve the ProcessingKey.NR_OF_RESULTS
fromlong
specifying the desired 'number of results' for a given operationCopyright © 2010–2023. All rights reserved.