Sepa DD Extension Point Client

<dependency>
    <groupId>com.iconsolutions.ipf.payments.csm.sepadd</groupId>
    <artifactId>sepadd-csm-extension-point-client-kafka</artifactId>
</dependency>

<dependency>
    <groupId>com.iconsolutions.ipf.payments.csm.sepadd</groupId>
    <artifactId>sepadd-csm-extension-point-client-jms</artifactId>
</dependency>

public interface MessageHandler<T> {

    CompletionStage<Outcome> handleMessage(ProcessingContext processingContext, T message);
    Class<T> forType();
    Direction forDirection();

    @Getter
    @RequiredArgsConstructor(access = AccessLevel.PRIVATE)
    class Outcome {
        private final ExtensionPointOutcome outcome;
        private final String rejectionReason;

        public static Outcome accept() {
            return new Outcome(ExtensionPointOutcome.ACCEPT, null);
        }

        public static Outcome reject(String rejectionReason) {
            return new Outcome(ExtensionPointOutcome.REJECT, rejectionReason);
        }

    }
}

@Component
@RequiredArgsConstructor
public class Pacs002FromSchemeMessageHandler implements MessageHandler<SDDFIToFIPaymentStatusReportV10> {

    private final SendConnector<SDDFIToFIPaymentStatusReportV10, SDDFIToFIPaymentStatusReportV10> schemeMessageSendConnector;

    @Override
    public CompletionStage<Outcome> handleMessage(ProcessingContext processingContext, SDDFIToFIPaymentStatusReportV10 message) {
        // Perform message level validation here and then forward the *entire* scheme message (grpHdr and transactions)
        if (message.getGrpHdr().getInstdAgt() == null) {
            return schemeMessageSendConnector.send(message)
                    .thenCompose(ignored -> Outcome.accept());
        } else {
            return CompletableFuture.completedStage(Outcome.reject("InstdAgt is not expected but was provided"));
        }
    }

    @Override
    public Class<SDDFIToFIPaymentStatusReportV10> forType() {
        return SDDFIToFIPaymentStatusReportV10.class;
    }

    @Override
    public Direction forDirection() {
        Direction.FROM_SCHEME;
    }
}