CloudEventify.MassTransit 2.1.102

dotnet add package CloudEventify.MassTransit --version 2.1.102
NuGet\Install-Package CloudEventify.MassTransit -Version 2.1.102
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="CloudEventify.MassTransit" Version="2.1.102" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add CloudEventify.MassTransit --version 2.1.102
#r "nuget: CloudEventify.MassTransit, 2.1.102"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install CloudEventify.MassTransit as a Cake Addin
#addin nuget:?package=CloudEventify.MassTransit&version=2.1.102

// Install CloudEventify.MassTransit as a Cake Tool
#tool nuget:?package=CloudEventify.MassTransit&version=2.1.102

CloudEvents[Rebus|MassTransit|Dapr]

nuget codecov stryker build status

TL;DR

Just a serializer/deserializer for cloud events.

Use CloudEvents

Rebus + RabbitMQ

Configure.With(new EmptyActivator())
    .Transport(t => t.UseRabbitMqAsOneWayClient(_container.ConnectionString))
    .Serialization(s => s.UseCloudEvents()
        .AddWithCustomName<UserLoggedIn>("io.cloudevents.demo.user.loggedIn") // explicit
        .AddWithShortName<UserLoggedIn>()) // or with short name
    .Start();

Rebus + Azure Service Bus

Configure.With(activator)
    .Transport(t => t
        .UseNativeHeaders()
        .UseAzureServiceBus($"Endpoint={ConnectionString}", queue, new DefaultAzureCredential()))
    .Options(o => o
        .UseCustomTypeNameForTopicName())
    .Serialization(s => s.UseCloudEvents()
        .AddWithCustomName<UserLoggedIn>("io.cloudevents.demo.user.loggedIn")) // <-- all types _must_ be mapped explicitly, either by short name or custom name
    .Start();

Using custom source for one-way clients:

Configure.OneWayClient()
    .Transport(t => t
        .UseNativeHeaders()
        .UseAzureServiceBusAsOneWayClient($"Endpoint={ConnectionString}", new DefaultAzureCredential()))
    .Options(o => o
        .UseSenderAddress("my-custom-source")
        .UseCustomTypeNameForTopicName())
    .Serialization(s => s.UseCloudEvents()
        .AddWithCustomName<UserLoggedIn>("io.cloudevents.demo.user.loggedIn")) // <-- all types _must_ be mapped explicitly, either by short name or custom name
    .Start();

MassTransit + RabbitMQ

On bus level:

var bus = Bus.Factory
    .CreateUsingRabbitMq(cfg =>
    {
        cfg.UseCloudEvents()
    };

On a specific receive endpoint:

var bus = Bus.Factory
    .CreateUsingRabbitMq(cfg =>
    {
        cfg.ReceiveEndpoint("...", x =>
        {
            x.UseCloudEvents();
        }
    };

This adds a deserializer to support incoming messages using the default application/cloudevents+json content type and sets the serializer to wrap outgoing messages in a cloud event envelope.

Message Types

All (custom) types must be explicitly mapped, both for outgoing and incoming messages.

.UseCloudEvents()
    .WithTypes(t => t.Map<UserLoggedIn>("loggedIn"));

Specify the type attribute on the cloud events envelope. Used by the deserializer when you want to deserialize to a specific (sub)type.

Subject

The subject can be constructed using the instance of the outgoing message (currently not available for Rebus).

.UseCloudEvents()
    .WithTypes(t => t.Map<UserLoggedIn>("loggedIn"), map => map with { Subject = x => x.SomeProperty });

Limitations

The use of cloud events is only developed for and tested in a pure pub/sub broker setup. It is safe to assume that other patterns supported by MassTransit will not work since the information required for that is not conveyed.

Interoperable

In the integration tests, dapr is used as publisher and subscriber to test both the serializer and deserializer.

Product Compatible and additional computed target framework versions.
.NET net5.0 was computed.  net5.0-windows was computed.  net6.0 was computed.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
.NET Core netcoreapp3.0 was computed.  netcoreapp3.1 was computed. 
.NET Standard netstandard2.1 is compatible. 
MonoAndroid monoandroid was computed. 
MonoMac monomac was computed. 
MonoTouch monotouch was computed. 
Tizen tizen60 was computed. 
Xamarin.iOS xamarinios was computed. 
Xamarin.Mac xamarinmac was computed. 
Xamarin.TVOS xamarintvos was computed. 
Xamarin.WatchOS xamarinwatchos was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
2.1.102 12,543 4/6/2023
2.1.96 1,006 3/8/2023
2.1.95 289 12/23/2022
2.1.85 284 12/5/2022
2.1.82 285 12/5/2022
2.1.74 304 12/1/2022
2.1.70 292 12/1/2022
2.1.67 328 11/21/2022
2.0.64 302 11/17/2022
2.0.61 387 11/4/2022
2.0.57 340 11/1/2022
2.0.56 358 11/1/2022
2.0.52 362 10/31/2022
1.3.28 432 10/14/2022
1.3.27 439 9/27/2022
1.3.22 584 3/8/2022
1.2.12 412 9/27/2021
1.0.11 560 9/15/2021
1.0.9 632 9/15/2021
1.0.7 303 9/14/2021
1.0.6 348 9/13/2021
1.0.5 319 9/13/2021

WithJsonOptions