Lightweight Message Bus for .Net Easy integration with multiple messaging frameworks including RabbitMQ, ActiveMQ ,maybe MSMQ
EasyBus.RabbitMQIntegration is on NuGet. To install it, run the following command in the Package Manager Console
Install-Package EasyBus.RabbitMQIntegration
Initialize IocBootstrapper
Container container = new Container();
//auto search all message handlers and register
container.RegisterSingle<ISubscriber>(new Subscriber(container));
var assembly = AppDomain.CurrentDomain.GetAssemblies().Where(x => x.FullName.Contains("EasyBus.Consumer")).FirstOrDefault();
var handlers = assembly.GetExportedTypes().Where(x => x.IsMessageHandler(typeof(MessageHandler<>))).ToList();
var responders = assembly.GetExportedTypes().Where(x => x.IsMessageHandler(typeof(MessageResponder<,>))).ToList();
container.RegisterAll<IMessageHandler>(handlers);
container.RegisterAll<IResponse>(responders);
container.RegisterSingle<IPublisher>(new Publisher(container));
container.RegisterSingle(new MessageEmitter(container));
container.RegisterSingle(new RabbitMQIntegrationModule(container));
Naming Convention for error strategy ......
<!--Number of multi-thread subscriber-->
<add key="MaxThreads" value="10" />
Pub / Sub Sample
// Find subsriber. (RabbitMQ, ActiveMQ etc.)
var subscriber = container.GetInstance<ISubscriber>();
// Find all message handlers in running process
var messageHandlers = container.GetAllInstances<IMessageHandler>();
console.WriteLine(messageHandlers.Count() + " subscriber found.", ConsoleColor.Green);
//Start to subscribe (async) for all message handlers
foreach (var item in messageHandlers)
{
subscriber.Subscribe(item);
}
Specify how the policy should handle consumer faults
<add key="RetryInterval" value="1" />
<add key="RetryCount" value="3" />
Policy.Execute<OperationResult>(() =>
{
}, message);