Rebus.nng

Provides a NNG (nanomsg-next-gen) transport for Rebus.

The library implements three patterns from the NNG:

• Producer/Consumer
• Request/Reply
• Publisher/Subscriber

Check out these links:

• NNG GitHub
• NNG .NET Wrapper

Check the Rebus.ng.TestConsole project for sample usage.

Producer

        services
            .AddRebus((configure, services) => configure
                .Transport(t => t.UseNngProducer("inproc://prodcons_test")));

Consumer

        services
            .AddRebus((configure, services) => configure
                .Transport(t => t.UseNngConsumer("inproc://prodcons_test")));

Request

        services
            .AddRebus((configure, services) => configure
                .Transport(t => t.UseNngRequest("inproc://repreq_test")));

Reply

        services
            .AddRebus((configure, services) => configure
                .Transport(t => t.UseNngReply("inproc://repreq_test")));

Publisher

        services
            .AddRebus((configure, services) => configure
                .Transport(t => t.UseNngPublisher("inproc://pubsub_test")));

Subscriber

        services
            .AddRebus((configure, services) => configure
                .Transport(t => t.UseNngSubscriber("inproc://pubsub_test")));