org.axonframework.axonserver.connector

Class DefaultInstructionAckSource<T>

java.lang.Object

org.axonframework.axonserver.connector.DefaultInstructionAckSource<T>

Type Parameters:

T - the type of message to be sent

All Implemented Interfaces:

InstructionAckSource<T>

public class DefaultInstructionAckSource<T>
extends Object
implements InstructionAckSource<T>

Default implementation of InstructionAckSource.

Since:

4.2.1

Author:

Milan Savic

Constructor Summary

Constructors

Constructor and Description
DefaultInstructionAckSource(Function<io.axoniq.axonserver.grpc.InstructionAck,T> messageCreator) Instantiates DefaultInstructionAckSource.

Method Summary

Modifier and Type	Method and Description
void	sendAck(String instructionId, boolean success, io.axoniq.axonserver.grpc.ErrorMessage error, io.grpc.stub.StreamObserver<T> stream) Sends an acknowledgement.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.axonserver.connector.InstructionAckSource

sendSuccessfulAck, sendUnsuccessfulAck, sendUnsupportedInstruction

Constructor Detail

DefaultInstructionAckSource

public DefaultInstructionAckSource(Function<io.axoniq.axonserver.grpc.InstructionAck,T> messageCreator)

Instantiates DefaultInstructionAckSource.

Parameters:

messageCreator - creates a message based on InstructionAck

Method Detail

sendAck

public void sendAck(String instructionId,
                    boolean success,
                    io.axoniq.axonserver.grpc.ErrorMessage error,
                    io.grpc.stub.StreamObserver<T> stream)

Description copied from interface: InstructionAckSource

Sends an acknowledgement.

Specified by:

sendAck in interface InstructionAckSource<T>

Parameters:

instructionId - identifier of successful instruction. If null, acknowledgement will not be sent.

success - true if acknowledgement is successful, false otherwise

error - the cause of the error. Provide null for successful acknowledgement

stream - the stream for sending acknowledgements