Hosting Integration

[ExternalTaskHandler("BestellungVerarbeiten")]
public class BestellungHandler : IExternalTaskHandler<BestellungInput, BestellungOutput>
{
    private readonly IBestellService _bestellService;
 
    public BestellungHandler(IBestellService bestellService)
    {
        _bestellService = bestellService;
    }
 
    public async Task<BestellungOutput> HandleAsync(
        BestellungInput input,
        ExternalTask task,
        CancellationToken cancellationToken)
    {
        Bestellung bestellung = await _bestellService.VerarbeiteAsync(input.BestellNr, cancellationToken);
 
        return new BestellungOutput
        {
            Status = bestellung.Status,
            LieferDatum = bestellung.GeschaetztesLieferDatum
        };
    }
}

IHostBuilder hostBuilder = Host.CreateDefaultBuilder(args);
 
// Services registrieren
hostBuilder.ConfigureServices(services =>
{
    services.AddScoped<IBestellService, BestellService>();
    services.AddScoped<BestellungHandler>(); // Scoped = neuer Scope pro Task
});
 
// External Task Worker aktivieren
hostBuilder.UseExternalTaskWorkers((context, options) =>
{
    options.ConfigureWorkers(context.Configuration.GetSection("ProcessCubeEngine"));
    options.AuthenticateUsingOAuth20ClientCredentials();
});

options.ConfigureForStudio(); // Konfiguriert für localhost:56000

public class MeineKlasse
{
    private readonly IExternalTaskProcessingController _controller;
 
    public async Task PauseVerarbeitung()
    {
        await _controller.StopExternalTaskProcessingAsync(CancellationToken.None);
        // Status: ExternalTaskProcessingStatus.Stopped
    }
 
    public async Task FortsetzungVerarbeitung()
    {
        await _controller.StartExternalTaskProcessingAsync(CancellationToken.None);
        // Status: ExternalTaskProcessingStatus.Processing
    }
}