Sepa CT Extension Point Client

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

<dependency>
    <groupId>com.iconsolutions.ipf.payments.csm.sepact</groupId>
    <artifactId>sepact-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
public class Pacs008FromSchemeMessageHandler implements MessageHandler<SCTFIToFICustomerCreditTransferV08> {
    @Override
    public CompletionStage<Outcome> handleMessage(ProcessingContext processingContext, SCTFIToFICustomerCreditTransferV08 message) {
        BigDecimal ttlAmount = message.getGrpHdr().getTtlIntrBkSttlmAmt().getValue();
        BigDecimal transactionAmountsSum = message.getCdtTrfTxInves().stream()
                .map(transaction -> transaction.getIntrBkSttlmAmt().getValue())
                .reduce(BigDecimal.ZERO, BigDecimal::add);

        if (Integer.getInteger(message.getGrpHdr().getNbOfTxs()).equals(message.getCdtTrfTxInves().size())
                && ttlAmount.compareTo(transactionAmountsSum) == 0) {
            return CompletableFuture.completedStage(Outcome.accept());
        } else {
            return CompletableFuture.completedStage(Outcome.reject("IntrBkSttlmAmt doesn't match"));
        }
    }

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

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