RawRabbit

Quick introduction

Configure, enrich and extend

varclient=RawRabbitFactory.CreateSingleton(newRawRabbitOptions{ClientConfiguration=newConfigurationBuilder().SetBasePath(Directory.GetCurrentDirectory()).AddJsonFile("rawrabbit.json").Build().Get<RawRabbitConfiguration>(),Plugins= p=>p.UseProtobuf().UsePolly(c=>c.UsePolicy(queueBindPolicy,PolicyKeys.QueueBind).UsePolicy(queueDeclarePolicy,PolicyKeys.QueueDeclare).UsePolicy(exchangeDeclarePolicy,PolicyKeys.ExchangeDeclare)),DependencyInjection= ioc=>ioc.AddSingleton<IChannelFactory,CustomChannelFactory>()});

Publish/Subscribe

varclient=RawRabbitFactory.CreateSingleton();awaitclient.SubscribeAsync<BasicMessage>(async msg=>{Console.WriteLine($"Received:{msg.Prop}.");});awaitclient.PublishAsync(newBasicMessage{Prop="Hello, world!"});

Request/Response

varclient=RawRabbitFactory.CreateSingleton();client.RespondAsync<BasicRequest,BasicResponse>(async request=>{returnnewBasicResponse();});varresponse=awaitclient.RequestAsync<BasicRequest,BasicResponse>();

Ack, Nack, Reject and Retry

varclient=RawRabbitFactory.CreateSingleton();awaitclient.SubscribeAsync<BasicMessage>(async msg=>{if(UnableToProcessMessage(msg)){returnnewNack(requeue:true);}ProcessMessage(msg)returnnewAck();});

varclient=RawRabbitFactory.CreateSingleton();awaitclient.SubscribeAsync<BasicMessage>(async msg=>{try{ProcessMessage(msg)returnnewAck();}catch(Exceptione){returnRetry.In(TimeSpan.FromSeconds(30));}});

Granular control for each call

awaitsubscriber.SubscribeAsync<BasicMessage>(received=>{receivedTcs.TrySetResult(received);returnTask.FromResult(true);}, ctx=>ctx.UseSubscribeConfiguration(cfg=>cfg.Consume(c=>c.WithRoutingKey("custom_key").WithConsumerTag("custom_tag").WithPrefetchCount(2).WithNoLocal(false)).FromDeclaredQueue(q=>q.WithName("custom_queue").WithAutoDelete().WithArgument(QueueArgument.DeadLetterExchange,"dlx")).OnDeclaredExchange(e=>e.WithName("custom_exchange").WithType(ExchangeType.Topic))));