message-broker

Publish Subscribe either Kafka, Redis, RabbitMQ on dotnet core

example located in MessageBroker.Example/Program.cs

set connection like:

ConnectionConfig connection = new ConnectionConfig(MessageBrokerEnum.RabbitMQ, "127.0.0.1", null);

IMessageBroker broker = messageFactory.Create(connection);

than start subscribe:

broker.Start("channel_name");

publish like:

broker.PublishRequestMessage(channel, objectToSend);