powered by simpleCommunicator - 2.0.35     © 2025 Programmizd 02
Форумы / ASP.NET [игнор отключен] [закрыт для гостей] / MassTransit - подключаюсь к новому сервису
1 сообщений из 1, страница 1 из 1
MassTransit - подключаюсь к новому сервису
    #40079407
RegisteredUser
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Гость
Добрый день, коллеги!

Был у меня проект, который хорошо общался через MassTransit с одним API.
Настройки был простые, как двери:


Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
в AppSettings
    "MobileServiceBusOptions": {
      "HostUri": "rabbitmq://rabbitmq.test.jin.com/jmobile",
      "UserName": "jmobile",
      "Password": "K****x",
      "Timeout": 20000,
      "Name_queue": "queueNr1"
     }

в Сервисе инициализировались все очереди вот так:

        private IRequestClient<Tin, Tout> GetRequestClientWithBus<Tin, Tout>(string queueName) where Tin : class where Tout : class
        {
            var serviceAddress = new Uri($"{_hostUri}/{queueName}"); // serviceAddress  - это "HostUri" / "Name_queue", т.е. = "rabbitmq://rabbitmq.test.jin.com/jmobile/queueNr1"
            var timeout = TimeSpan.FromMilliseconds(_options.Value.Timeout);
            return new MessageRequestClient<Tin, Tout>(_bus, serviceAddress, timeout);
        }

Всё нормально работает без проблем.




Теперь появился новый сервис, к которому надо коннектится через другой кролик.
И тут такая простая схема не срабатывает.
Подскажите плиз почему?


Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
в AppSettings
    "MobileServiceBusOptions": {
    "HostUri": "rabbitmq://tv-web.stin.com/jelell_p",
    "UserName": "electrobill",
    "Password": "q*****k",
    "Timeout": 20000,
    "Name_queue": "v3/wbill/payment/check"
     }


        private IRequestClient<Tin, Tout> GetRequestClientWithBus<Tin, Tout>(string queueName) where Tin : class where Tout : class
        {
            var serviceAddress = new Uri($"{_hostUri}/{queueName}"); 
            // такая схема теперь не работает:  
           // serviceAddress  - это "HostUri" / "Name_queue", т.е. = "rabbitmq://tv-web.stin.com/jelell_p/v3/wbill/payment/check"
            var timeout = TimeSpan.FromMilliseconds(_options.Value.Timeout);
            return new MessageRequestClient<Tin, Tout>(_bus, serviceAddress, timeout);
        }




Подскажите, что не так делаем?
...
Рейтинг: 0 / 0
1 сообщений из 1, страница 1 из 1
Форумы / ASP.NET [игнор отключен] [закрыт для гостей] / MassTransit - подключаюсь к новому сервису
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Найденые пользователи ...
Разблокировать пользователей ...
Читали форум (0):
Пользователи онлайн (0):
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]