Тематическая маршрутизация с неуниверсальным EasyNetQ не фильтрует

Мы собираемся разместить данные между приложением C++ и приложением.NET Поскольку типы не могут быть одинаковыми, я выбрал неуниверсальную подписку.

     bus.Subscribe(typeof(string), "my_subscriptionId", messageStr =>
            {
                TextMessage txtMsg = JsonConvert.DeserializeObject<TextMessage>(messageStr.ToString());
                var consumer = new TextMessageConsumer();
                consumer.ConsumeMessage(txtMsg);
            }, (c)=> { c.WithTopic("MainTopic.*"); });

Я делаю две публикации

bus.Publish(msgSer, "MainTopic.hot_topic");
bus.Publish(msgSerCold, "totallydifferent");

Но я получаю оба сообщения. Я ожидал получить только первый. Не понимаю ли я это?

0 ответов

Другие вопросы по тегам