dario-l / easynetq Goto Github PK

    var bus = RabbitHutch.CreateBus("host=localhost");

    await bus.PubSub.PublishAsync(message);

    await bus.Scheduler.FuturePublishAsync(message, TimeSpan.FromSeconds(5));

    await bus.PubSub.SubscribeAsync<MyMessage>(
        "my_subscription_id", msg => Console.WriteLine(msg.Text)
    );

    var request = new TestRequestMessage {Text = "Hello from the client! "};
    await bus.Rpc.RequestAsync<TestRequestMessage, TestResponseMessage>(request);

    await bus.Rpc.RespondAsync<TestRequestMessage, TestResponseMessage>(request =>
        new TestResponseMessage{ Text = request.Text + " all done!" }
    );