KnightBus is a fast, lightweight and extensible messaging framework that supports multiple active message transports

Transports

Monitoring

Serialization

Framework

Message Processing

publicclassCommandProcessor:IProcessCommand<SampleCommand,SampleSettings>,{publicCommandProcessor(ISomeDependencydependency){//You can use your own container for dependency injection}publicTaskProcessAsync(SampleCommandmessage,CancellationTokencancellationToken){//Your code goes herereturnTask.CompletedTask;}}

Initialization

classProgram{staticasyncTaskMain(string[]args){varhost=Microsoft.Extensions.Hosting.Host.CreateDefaultBuilder(args).ConfigureServices(services=>{//Multiple active transportsservices.UseServiceBus(config=>config.ConnectionString="sb-connection").UseTransport<ServiceBusTransport>().UseBlobStorage(config=>config.ConnectionString="storage-connection").UseTransport<StorageTransport>().RegisterProcessors();}).UseKnightBus().Build();awaithost.StartAsync(CancellationToken.None);}}

Bring your own Middleware

publicclassCustomThrottlingMiddleware:IMessageProcessorMiddleware{privatereadonlySemaphoreQueue_semaphoreQueue;publicintCurrentCount=>_semaphoreQueue.CurrentCount;publicCustomThrottlingMiddleware(intmaxConcurrent){_semaphoreQueue=newSemaphoreQueue(maxConcurrent);}publicasyncTaskProcessAsync<T>(IMessageStateHandler<T>messageStateHandler,IPipelineInformationpipelineInformation,IMessageProcessornext,CancellationTokencancellationToken)whereT:class,IMessage{try{await_semaphoreQueue.WaitAsync().ConfigureAwait(false);awaitnext.ProcessAsync(messageStateHandler,cancellationToken).ConfigureAwait(false);}finally{_semaphoreQueue.Release();}}}

Write your own Plugin

publicclassCustomPlugin:IPlugin{publicCustomPlugin(ISomeDependencydependency,ILogger<CustomPlugin>logger){}publicasyncTaskStartAsync(CancellationTokencancellationToken){// Start the plugin}}

Documentation

#In documentation folder:$sudo apt install python3 python3-sphinx python3-pip$python3 -m pip install sphinx-rtd-theme$make htmlsource build$sensible-browser build/html/index.html