Class TestingHelper<TBroker>

Inheritance
System.Object
TestingHelper<TBroker>
KafkaTestingHelper
MqttTestingHelper
Implements
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Testing
Assembly: Silverback.Integration.Testing.dll
Syntax
public abstract class TestingHelper<TBroker> : ITestingHelper<TBroker> where TBroker : IBroker
Type Parameters
Name Description
TBroker

Constructors

| Improve this doc View source

TestingHelper(IServiceProvider, ILogger<TestingHelper<TBroker>>)

Initializes a new instance of the TestingHelper<TBroker> class.

Declaration
protected TestingHelper(IServiceProvider serviceProvider, ILogger<TestingHelper<TBroker>> logger)
Parameters
Type Name Description
System.IServiceProvider serviceProvider

The System.IServiceProvider.
Microsoft.Extensions.Logging.ILogger<TestingHelper<TBroker>> logger

The Microsoft.Extensions.Logging.ILogger<TCategoryName>.

Properties

| Improve this doc View source

Broker

Declaration
public TBroker Broker { get; }
Property Value
Type Description
TBroker
| Improve this doc View source

Spy

Declaration
public IIntegrationSpy Spy { get; }
Property Value
Type Description
IIntegrationSpy

Methods

| Improve this doc View source

IsOutboxEmptyAsync()

Declaration
public async Task<bool> IsOutboxEmptyAsync()
Returns
Type Description
System.Threading.Tasks.Task<System.Boolean>
| Improve this doc View source

WaitUntilAllMessagesAreConsumedAsync(Boolean, Nullable<TimeSpan>)

Declaration
public abstract Task WaitUntilAllMessagesAreConsumedAsync(bool throwTimeoutException, TimeSpan? timeout = null)
Parameters
Type Name Description
System.Boolean throwTimeoutException
System.Nullable<System.TimeSpan> timeout
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

WaitUntilAllMessagesAreConsumedAsync(Nullable<TimeSpan>)

Declaration
public Task WaitUntilAllMessagesAreConsumedAsync(TimeSpan? timeout = null)
Parameters
Type Name Description
System.Nullable<System.TimeSpan> timeout
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

WaitUntilConnectedAsync(Boolean, Nullable<TimeSpan>)

Declaration
public async Task WaitUntilConnectedAsync(bool throwTimeoutException, TimeSpan? timeout = null)
Parameters
Type Name Description
System.Boolean throwTimeoutException
System.Nullable<System.TimeSpan> timeout
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

WaitUntilConnectedAsync(Nullable<TimeSpan>)

Declaration
public Task WaitUntilConnectedAsync(TimeSpan? timeout = null)
Parameters
Type Name Description
System.Nullable<System.TimeSpan> timeout
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

WaitUntilOutboxIsEmptyAsync(CancellationToken)

Declaration
public async Task WaitUntilOutboxIsEmptyAsync(CancellationToken cancellationToken)
Parameters
Type Name Description
System.Threading.CancellationToken cancellationToken
Returns
Type Description
System.Threading.Tasks.Task

Implements