Sending Connector Quickstart

SendConnector<ExampleType, ExampleType> connector = SendConnector
        .<ExampleType, ExampleType>builder("ExampleSystem") (1)
        .withConnectorTransport(transport) (2)
        .withSendTransportMessageConverter(converter)(3)
        .withCorrelationIdExtractor(correlationIdExtractor) (4)
        .withCorrelationService(correlationService) (5)
        .withActorSystem(actorSystem) (6)
        .build();

public interface SendingConnector<D, R> extends OperableConnector {

    /**
     * Send a request via the connector without a supporting context
     */
    default CompletionStage<R> send(@NotNull ProcessingContext processingContext,
                                    @NotNull D domainMessage) {
        return send(processingContext, domainMessage, SupportingContext.empty());
    }

    /**
     * Send a request via the connector with a full sending context
     * that allows users to supply a supporting context as well
     */
    CompletionStage<R> send(@NotNull ProcessingContext processingContext,
                            @NotNull D domainMessage,
                            @NotNull SupportingContext supportingContext);

    /**
     * Allows setting of the meterRegistry implementation for a connector
     * after connector build
     * This allows implementations to set the registry for all SendingConnector instances
     * at once instead of having to set them at a per connector bases at build time
     */
    void setMeterRegistry(MeterRegistry meterRegistry);

    SendingConnectorConfig getConfig();
}

@Data
@AllArgsConstructor
@EqualsAndHashCode
public static class ExampleType implements UpdatebleProcessingContextHolder {
    private final String name;
    private final LocalDate dob;
    private final int shoeSize;
    private ProcessingContext processingContext;

    public ExampleType(String name, LocalDate dob, int shoeSize) {
        this(name, dob, shoeSize, null);
    }
}

ExampleType message = new ExampleType(
        "Isaac Newton",
        LocalDate.of(1642, 12, 25),
        8
);
CompletionStage<DeliveryOutcome> future = connector.send(processingContext, message);