EndpointConfigurationBuilder

EndpointConfigurationBuilder.cs

public class EndpointConfigurationBuilder
{
    private EndpointConfiguration _endpointConfiguration;
    public EndpointConfigurationBuilder(string endpointName)
    {
        _endpointConfiguration = new EndpointConfiguration(endpointName);
    }

    public EndpointConfigurationBuilder UseTransport<TTransport>(
        TTransport transportDefinition,
        Action<RoutingSettings<TTransport>> configureRouting)
        where TTransport : TransportDefinition
    {
        var routingSettings = _endpointConfiguration.UseTransport(transportDefinition);
        configureRouting(routingSettings);
        return this;
    }

    public EndpointConfigurationBuilder UsePersistence<TPersistence>(
        Action<PersistenceExtensions<TPersistence>>? configurePersistence = null)
        where TPersistence : PersistenceDefinition
    {
        var persistenceExtensions = _endpointConfiguration.UsePersistence<TPersistence>();
        configurePersistence?.Invoke(persistenceExtensions);
        return this;
    }

    public EndpointConfigurationBuilder ConfigureRecoverability(Action<RecoverabilitySettings>? configureRecoverability = null)
    {
        var recoverability = _endpointConfiguration.Recoverability();
        configureRecoverability?.Invoke(recoverability);

        return this;
    }

    public EndpointConfigurationBuilder ConfigurePipeline(Action<PipelineSettings>? configurePipeline = null)
    {
        var pipeline = _endpointConfiguration.Pipeline;
        configurePipeline?.Invoke(pipeline);
        return this;
    }

    public EndpointConfigurationBuilder UseSerialization<TSerializer>(
        Action<SerializationExtensions<TSerializer>>? configureSerializer = null)
        where TSerializer : SerializationDefinition, new()
    {
        var serializer =
            _endpointConfiguration.UseSerialization<TSerializer>();

        configureSerializer?.Invoke(serializer);
        
        return this;
    }

    public EndpointConfigurationBuilder RegisterComponents(Action<IServiceCollection> registerServices)
    {
        _endpointConfiguration.RegisterComponents(registerServices);
        
        return this;
    }
    
    private EndpointConfigurationBuilder RegisterMessageMutator<T> (T messageMutator)
    {
        _endpointConfiguration.RegisterMessageMutator(messageMutator);
        return this;
    }
    
    public EndpointConfigurationBuilder RegisterMessageMutator(IMutateOutgoingMessages messageMutator)
    {
        RegisterMessageMutator(messageMutator);
        return this;
    }
    public EndpointConfigurationBuilder RegisterMessageMutator(IMutateOutgoingTransportMessages messageMutator)
    {
        RegisterMessageMutator(messageMutator);
        return this;
    }
    public EndpointConfigurationBuilder RegisterMessageMutator(IMutateIncomingTransportMessages messageMutator)
    {
        RegisterMessageMutator(messageMutator);
        return this;
    }
    
    public EndpointConfigurationBuilder RegisterMessageMutator(IMutateIncomingMessages messageMutator)
    {
        RegisterMessageMutator(messageMutator);
        return this;
    }
    

    public EndpointConfiguration Build()
    {
        return _endpointConfiguration;
    }
}