NServiceBus by Particular Software

<PackageReference Include="NServiceBus" Version="7.8.0" />

.NET API 1,065,984 bytes

 TransportReceiveInfrastructure

public class TransportReceiveInfrastructure
Represents the infrastructure of the transport used for receiving.
public Func<IPushMessages> MessagePumpFactory { get; }

Factory for creating a message pump for each queue to be consumed from.

public Func<Task<StartupCheckResult>> PreStartupCheck { get; }

Callback to perform checks before the transports starts receiving messages.

public Func<ICreateQueues> QueueCreatorFactory { get; }

Factory for the queue creator.

public TransportReceiveInfrastructure(Func<IPushMessages> messagePumpFactory, Func<ICreateQueues> queueCreatorFactory, Func<Task<StartupCheckResult>> preStartupCheck)

Creates new result.