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.