Interface IBrokerClientsConnector

Namespace

Silverback.Messaging.Broker

Assembly

Silverback.Integration.dll

Initializes and connects the configured producers and consumers.

public interface IBrokerClientsConnector

Methods

ConnectAllAsync(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 ConnectAllAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

A CancellationToken used to cancel the operation.

Returns

ValueTask

A ValueTask representing the asynchronous operation.

DisconnectAllAsync()

Disconnects all the producers and consumers.

ValueTask DisconnectAllAsync()

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.