Silverback.Integration.MQTT.Testing 5.0.0-beta.3

<img src="https://github.com/BEagle1984/silverback/raw/master/docs/images/logo.png" alt="Silverback">

Silverback is a powerful, elegant, and feature-rich message bus for .NET, designed to simplify asynchronous messaging, event-driven architectures, and microservice communication. With seamless integration for Apache Kafka and MQTT, it offers robust features for reliability, consistency, and scalability.

Whether you're building a small microservice, a large-scale enterprise solution, or anything in between, Silverback provides the tools to make messaging effortless and reliable.

Why Choose Silverback?

Silverback is designed for serious workloads, offering enterprise-grade capabilities with a rich feature set optimized for performance, resilience, and scalability.

Key Features

🔀 Powerful Message Bus
A simple but powerful in-memory message bus enables seamless communication between components, featuring Rx.NET support for reactive programming.

🔗 Seamless Message Broker Integration
Silverback makes it easy to integrate with Kafka and MQTT, providing a streamlined and developer-friendly API to build event-driven architectures with minimal setup and configuration.

🚀 Kafka-Optimized Messaging
Unlike generic messaging libraries, Silverback is built specifically for Kafka, leveraging its unique capabilities for high-throughput, exactly-once semantics, and partitioned processing. While Silverback also supports MQTT, Kafka is a first-class citizen, and the framework is highly optimized to take full advantage of its power.

📤 Transactional Outbox
Ensures message consistency by linking database transactions with messaging, preventing message loss and guaranteeing atomicity.

⚠️ Advanced Error Handling
Define flexible strategies to retry, skip, or move messages based on custom policies, ensuring robustness in failure scenarios.

📦 Batch Processing & Chunking
Enhances efficiency by processing messages in bulk or splitting large messages into smaller chunks, which are automatically reassembled on the receiving end.

⚡ Domain-Driven Design (DDD) Support
Automates domain event publishing when entities are persisted, ensuring seamless integration with message brokers for event-driven workflows.

✅ Exactly-Once Processing
Ensures each message is consumed and processed exactly once, preventing duplicate processing and maintaining data integrity.

🔍 Distributed Tracing
Leverages System.Diagnostics for full visibility into message flow and distributed transaction tracking.

🧪 Testability
Provides in-memory mocks for Kafka and MQTT, along with powerful helpers for efficient unit testing.

✨ And much more!
Silverback is highly extensible, making it the go-to messaging framework for .NET developers who want to harness Kafka’s full potential while maintaining flexibility for other brokers.

Discover more in the project's website.

Project Status

Continuous Build

Sonar Build

Quality Metrics

Activity

Setting Up Silverback

Silverback is designed as a modular framework, allowing you to include only the components you need. This guide walks you through selecting the right packages and configuring the basics to get started.

Adding the Required Packages

Core Packages

• Silverback.Core – The essential package, including the message bus and fundamental messaging components.
• Silverback.Core.Model – Enhances CQRS and event-driven architectures with improved semantics.

Message Broker Integration

If you need to integrate with a message broker, choose the appropriate package:

• Silverback.Integration.Kafka – Adds Kafka support (implicitly includes Silverback.Core).
• Silverback.Integration.Mqtt – Adds MQTT support (implicitly includes Silverback.Core).

Additional Features

• Silverback.Core.Rx – Enables Rx.NET integration, allowing observables from the message bus stream.
• Silverback.Newtonsoft – Supports serialization using Newtonsoft.Json instead of System.Text.Json.
• Silverback.Kafka.SchemaRegistry – Provides integration with Schema Registry for Protobuf, Avro, or JSON serialization with schema support.

Storage Options

Certain Silverback features rely on a storage mechanism. Choose the appropriate package based on your needs:

• Silverback.Storage.PostgreSql – Optimized for PostgreSQL, leveraging advisory locks.
• Silverback.Storage.Sqlite – A lightweight option, ideal for testing.
• Silverback.Storage.EntityFramework – Works with Entity Framework, supporting all EF-compatible relational databases.
• Silverback.Storage.Memory – An in-memory storage option, useful for testing.

Testing Support

For unit testing message-driven applications, you can use in-memory broker mocks:

• Silverback.Integration.Kafka.Testing – Provides an in-memory Kafka mock, simulating partitioning, offsets management, and other broker behaviors.
• Silverback.Integration.Mqtt.Testing – Provides an in-memory MQTT mock to test MQTT-related logic.

Usage

Have a look at the project's website for usage details, API documentation and samples.

Contributing

You are encouraged to contribute to Silverback! Please check out the how to contribute guide for guidelines about how to proceed.

License

This code is licensed under MIT license (see LICENSE file for details)