Исправьте код и настройки как для издателя, так и для подписчика с Rebus - PullRequest
Новая
       27

Исправьте код и настройки как для издателя, так и для подписчика с Rebus

0 голосов
/ 29 мая 2019

Правильны ли код и комментарии ниже 1 - 7?

//7  below is not needed for both publisher and subscriber    
// .Routing(r => r.TypeBased().MapAssemblyOf<string>(Consts.Publisher))

Подписчик1 

 Configure.With(activator)
                .Logging(l => l.ColoredConsole(minLevel: LogLevel.Warn))
                 .Transport(t => t.UseAzureServiceBus(Consts.ServiceBusConnectionString, Consts.Subscriber1))
                //7  below is not needed for both publisher and subscriber
                // .Routing(r => r.TypeBased().MapAssemblyOf<string>(Consts.Publisher))   
                .Options(o =>
                {
                    //1 can be used for both publisher and subscriber
                    o.Register<ITopicNameConvention>(c => new SimpleTopicNameConvention());

                    //2 only used by consumer
                    o.Decorate<IErrorHandler>(c => new MyErrorHandler(c.Get<IErrorHandler>()));

                    //3 only used by consumer
                    o.SimpleRetryStrategy(maxDeliveryAttempts: 2,
                        errorQueueAddress: "poison");

                    //4 only used by consumer
                    o.SetNumberOfWorkers(5);
                    o.SetMaxParallelism(30);

                    //5 only used by consumer
                    o.SetBackoffTimes(
                        TimeSpan.FromMilliseconds(100),
                        TimeSpan.FromMilliseconds(200),
                        TimeSpan.FromSeconds(1));

                    //6 only used by consumer
                    o.Register<IBackoffStrategy>(c =>
                    {
                        var strategy = new MyBackoffStrategy();
                        return strategy;
                    });

                }).Start();
...