Namespace Silverback.Messaging.Broker.Callbacks

Classes

BrokerCallbackInvocationException

The exception that wraps the exception thrown by a IBrokerCallback.

Interfaces

IBrokerCallback

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

IBrokerCallbacksInvoker

Used to invoke the registered IBrokerCallback.

IEndpointsConfiguredCallback

Declares the OnEndpointsConfiguredAsync() callback.

IKafkaConsumerErrorCallback

Declares the OnConsumerError(Error, KafkaConsumer) event handler.

IKafkaConsumerLogCallback

Declares the OnConsumerLog(LogMessage, KafkaConsumer) event handler.

IKafkaConsumerStatisticsCallback

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

IKafkaOffsetCommittedCallback

Declares the OnOffsetsCommitted(CommittedOffsets, KafkaConsumer) event handler.

IKafkaPartitionEofCallback

Declares the OnEndOfTopicPartitionReached(TopicPartition, KafkaConsumer) event handler.

IKafkaPartitionsAssignedCallback

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

IKafkaPartitionsRevokedCallback

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

IKafkaProducerLogCallback

Declares the OnProducerLog(LogMessage, KafkaProducer) event handler.

IKafkaProducerStatisticsCallback

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

IMqttClientConnectedCallback

Declares the OnClientConnectedAsync(MqttClientConfig) event handler.

IMqttClientDisconnectingCallback

Declares the OnClientDisconnectingAsync(MqttClientConfig) event handler.