Namespace Silverback.Messaging.Broker
Classes
- BrokerClient
Wraps the underlying client libraries (e.g. Kafka consumers and producers or Mqtt clients) and handles the connection lifecycle.
- Consumer<TIdentifier>
Consumes from one or more endpoints and pushes the received messages via the message bus.
- KafkaConsumer
Consumes from one or more endpoints and pushes the received messages via the message bus.
- KafkaConsumerLocalTimeoutMonitor
Handles the consumer error callback and reverts the consumer Connected status to Started when the local poll timeout is exceeded. The consumer should eventually reconnect but this allows to accurately track its status.
- KafkaOffset
Represents the position of the message in a partition.
- KafkaProducer
Produces the messages to an endpoint.
- KafkaTransactionalProducer
Produces the messages to an endpoint.
- MissingKafkaTransactionException
The exception that is thrown when a transactional producer is used but the transaction has not been initialized.
- MqttConsumer
Consumes from one or more endpoints and pushes the received messages via the message bus.
- MqttMessageIdentifier
The MQTT broker doesn't provide any message identifier, so this is a client-side generated identifier (GUID).
- MqttProducer
Produces the messages to an endpoint.
- ProduceException
The exception that is thrown by the IProducer when the message cannot be produced or the message broker didn't acknowledge it.
- Producer
Produces the messages to an endpoint.
Interfaces
- IBrokerClient
Wraps the underlying client libraries (e.g. Kafka consumers and producers or Mqtt clients) and handles the connection lifecycle.
- IBrokerClientCollection
Holds a reference to all the configured IBrokerClient.
- IBrokerClientsConnector
Initializes and connects the configured producers and consumers.
- IBrokerMessageIdentifier
The primary identifier used by the message broker to recognize the exact message. It can represent a Kafka offset or other similar constructs. If the message broker doesn't provide any message identifier, a local one can be created (e.g.
Guid.NewGuid()) and it will be used to match the message to be committed.
- IConsumer
Consumes from one or more endpoints and pushes the received messages via the message bus.
- IConsumerCollection
Holds a reference to all the configured IConsumer.
- IConsumerStatusChange
Encapsulates the information about the consumer status transition.
- IConsumerStatusInfo
Encapsulates the status details and basic statistics of an IConsumer.
- IKafkaConsumer
Consumes from one or more endpoints and pushes the received messages via the message bus.
- IKafkaTransactionalProducerCollection
Return a KafkaProducer that can be used to produce messages in a transaction. These producer are used through the KafkaTransactionalProducer.
- IProducer
Produces the messages to an endpoint.
- IProducerCollection
Returns an IProducer that can be used to produce messages against the message broker.
Enums
- ClientStatus
The possible states of an IBrokerClient.
- ConsumerStatus
The possible states of the IConsumer as exposed in the IConsumerStatusInfo.