CloudEventify.MassTransit 1.2.12

MassTransit+CloudEvents

TL;DR

Just a serializer/deserializer for cloud events.

Use CloudEvents

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.

Content Type

cfg.UseCloudEvents()
    .WithContentType(new ContentType("text/plain"));

Sets the content-type for both the serializer and the deserializer. For example when the publishing side chooses a different content type.

You can invoke the UseCloudEvents with a different ContentType multiple times but the last one wins for the outbound (serializer) configuration.

Message Types

cfg.UseCloudEvents()
    .Type<UserLoggedIn>("loggedIn");

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

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.