CloudEventify.Rebus 2.0.52

CloudEvents[Rebus|MassTransit|Dapr]

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()
        .WithTypes(types => types.Map<UserLoggedIn>("loggedIn")))
    .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.

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

Source

For Rebus you can also specify the Source attribute to be applied on the outgoing cloud event:

.Serialization(s => s.UseCloudEvents()
    .WithTypes(types => types.Map<UserLoggedIn>("user.loggedIn"))
    .WithSource(new System.Uri("uri:MySourceApp")))

Using MassTransit the Source attribute is used from the SendContext.

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.