Namespace Silverback.Messaging.Broker.Callbacks

Classes

BrokerClientCallbackInvocationException

The exception that wraps the exception thrown by a IBrokerClientCallback.

Interfaces

IBrokerClientCallback

The marker interface implemented by all interfaces declaring the client callbacks handlers.

IBrokerClientCallbacksInvoker

Used to invoke the registered IBrokerClientCallback.

IBrokerClientsConfiguredCallback

Declares the OnBrokerClientsConfiguredAsync() callback.

IBrokerClientsConnectedCallback

Declares the OnBrokerClientsConnectedAsync() callback.

IKafkaConsumerErrorCallback

Declares the OnConsumerError(Error, IKafkaConsumer) event handler.

IKafkaConsumerLogCallback

Declares the OnConsumerLog(LogMessage, IKafkaConsumer) event handler.

IKafkaConsumerStatisticsCallback

Declares the OnConsumerStatistics(KafkaStatistics?, string, IKafkaConsumer) event handler.

IKafkaOffsetCommittedCallback

Declares the OnOffsetsCommitted(CommittedOffsets, IKafkaConsumer) event handler.

IKafkaPartitionEofCallback

Declares the OnEndOfTopicPartitionReached(TopicPartition, IKafkaConsumer) event handler.

IKafkaPartitionsAssignedCallback

Declares the OnPartitionsAssigned(IReadOnlyCollection<TopicPartition>, IKafkaConsumer) event handler.

IKafkaPartitionsRevokedCallback

Declares the OnPartitionsRevoked(IReadOnlyCollection<TopicPartitionOffset>, IKafkaConsumer) event handler.

IKafkaProducerLogCallback

Declares the OnProducerLog(LogMessage, IConfluentProducerWrapper) event handler.

IKafkaProducerStatisticsCallback

Declares the OnProducerStatistics(KafkaStatistics?, string, IConfluentProducerWrapper) event handler.

IMqttClientConnectedCallback

Declares the OnClientConnectedAsync(MqttClientConfiguration) event handler.

IMqttClientDisconnectingCallback

Declares the OnClientDisconnectingAsync(MqttClientConfiguration) event handler.