sergeyshaykhullin

dbug: Microsoft.Extensions.Hosting.Internal.Host[1]
      Hosting starting
info: MassTransit[0]
      Configured endpoint queuestep1, Consumer: ExchangeToExchangeBinding.Worker.Step1Consumer
info: MassTransit[0]
      Configured endpoint queuestep2, Consumer: ExchangeToExchangeBinding.Worker.Step2Consumer
info: MassTransit[0]
      Configured endpoint queuestep3, Consumer: ExchangeToExchangeBinding.Worker.Step3Consumer
dbug: MassTransit.Transports.BusDepot[0]
      Starting bus instances: IBus

sergeyshaykhullin

dbug: Microsoft.Extensions.Hosting.Internal.Host[1]
      Hosting starting
dbug: MassTransit.Transports.BusDepot[0]
      Starting bus instances: IBus
dbug: MassTransit[0]
      Starting bus: rabbitmq://localhost/
dbug: MassTransit[0]
      Connect: guest@localhost:5672/
dbug: MassTransit[0]
      Connected: guest@localhost:5672/ (address: amqp://localhost:5672, local: 58086)

sergeyshaykhullin

static void Main()
{
	using (var connection = new ConnectionFactory().CreateConnection())
	{
		using (var channel1 = connection.CreateModel())
		{
			//                   queue1 -> produce click to queue2
			// click -> exchange
			//                   queue2 -> consume click from queue1
			channel1.ExchangeDeclare("exchange", ExchangeType.Direct, autoDelete: true);

sergeyshaykhullin

static void Main()
{
	using (var connection = new ConnectionFactory { DispatchConsumersAsync = true }.CreateConnection())
	{
		using (var channel1 = connection.CreateModel())
		{
			//                   queue1 -> produce click to queue2
			// click -> exchange
			//                   queue2 -> consume click from queue1
			channel1.ExchangeDeclare("exchange", ExchangeType.Direct, autoDelete: true);

sergeyshaykhullin

var f = new ConnectionFactory();

var c = f.CreateConnection("test");

var m = c.CreateModel();

m.QueueDeclare("test_queue");

m.ExchangeDeclare("test_exchange", "direct");