Interface IBrokerClientsConnector

Namespace

Silverback.Messaging.Broker

Assembly

Silverback.Integration.dll

Initializes and connects the configured producers and consumers.

public interface IBrokerClientsConnector

Methods

ConnectAsync(CancellationToken)

Calls all the IBrokerClientsInitializer and initializes the producers and consumers (if InitializeAsync() wasn't called yet), then initializes the connection to the message broker(s).

ValueTask ConnectAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

A CancellationToken used to cancel the operation.

Returns

ValueTask

A ValueTask representing the asynchronous operation.

DisconnectAsync()

Disconnects all the producers and consumers.

ValueTask DisconnectAsync()

Returns

ValueTask

A ValueTask representing the asynchronous operation.

InitializeAsync()

Calls all the IBrokerClientsInitializer and initializes the producers and consumers.

ValueTask InitializeAsync()

Returns

ValueTask

A ValueTask representing the asynchronous operation.

StopConsumersAsync()

Stops all the consumers to prevent them from consuming any more messages.

ValueTask StopConsumersAsync()

Returns

ValueTask

A ValueTask representing the asynchronous operation.