You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
Mark van Renswoude 8e69c79b94 Merge branch 'release/2.5' into develop 1 week ago
Examples Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti Implemented RoutingKey attribute 2 weeks ago
Tapeti.Annotations Implemented RoutingKey attribute 2 weeks ago
Tapeti.Autofac Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.CastleWindsor Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.Cmd Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.DataAnnotations Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.DataAnnotations.Extensions Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.Flow Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.Flow.SQL Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.Ninject Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.Serilog Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.SimpleInjector Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.Tests Implemented RoutingKey attribute 2 weeks ago
Tapeti.Transient Updated all references NuGet packages to latest stable version 3 weeks ago
Tapeti.UnityContainer Updated all references NuGet packages to latest stable version 3 weeks ago
build Changed version number strategy to include CommitsSinceVersionSource 2 years ago
docs Implemented a rate limiting option for Tapeti.Cmd 12 months ago
resources Added Tapeti.Flow.SQL to AppVeyor build 3 years ago
.gitignore Implemented EasyNetQ Hosepipe compatibility for Tapeti.cmd [ci skip] 2 years ago
GitVersion.yml Preparations for NuGet push 4 years ago
README.md Readme updated for 2.0 merge 2 years ago
Tapeti.png [ci skip] Major refactoring for 2.0 2 years ago
Tapeti.sln Implemented a rate limiting option for Tapeti.Cmd 12 months ago
Tapeti.sln.DotSettings Start of Tapeti.Cmd [ci skip] 2 years ago
UNLICENSE Preparations for NuGet push 4 years ago
appveyor.yml Artifact filter ignored snupkg 2 weeks ago

README.md

Introduction

Tapeti is a wrapper for the RabbitMQ .NET Client designed for long-running microservices. It’s main goal is to minimize the amount of messaging code required, and instead focus on the higher-level flow.

Key features

  • Consumers are declared using MVC-style controllers and are registered automatically based on annotations
  • Publishing requires only the message class, no transport details such as exchange and routing key
  • Flow extension (stateful request - response handling with support for parallel requests)
  • No inheritance required
  • Graceful recovery in case of connection issues, and in contrast to most libraries not designed for services, during startup as well
  • Extensible using middleware

Show me the code!

Below is a bare minimum message controller from the first example project to get a feel for how messages are handled using Tapeti.

/// <summary>
/// Example of a simple broadcast message used in the standard publish - subscribe pattern
/// </summary>
public class PublishSubscribeMessage
{
    [Required(ErrorMessage = "Don't be impolite, supply a {0}")]
    public string Greeting { get; set; }
}


[MessageController]
[DynamicQueue("tapeti.example.01")]
public class ExampleMessageController
{
    public ExampleMessageController() { }

    public void HandlePublishSubscribeMessage(PublishSubscribeMessage message)
    {
        Console.WriteLine("Received message: " + message.Greeting);
    }
}

More details and examples can be found in the documentation as well as the example projects included with the source.

Documentation

The documentation for Tapeti is available on Read the Docs:

Master branch (stable release)
Documentation Status

Develop branch
Documentation Status

Builds

Builds are automatically run using AppVeyor, with the resulting packages being pushed to NuGet.

Master build (stable release) Build status

Latest build Build status