2016-08-03 8 views
1

Я использую поставщика EventHubStream в проекте, основанном на Орлеане. После того, как система работает несколько минут, Орлеан начинает бросать исключение QueueCacheMissException, пытаясь вытолкнуть событие в OnNext от производителя.Поставщик потока Orleans EventHub

Я попытался увеличить размер кеша, но это помогло только некоторое время.

Это обычное поведение из-за размера кеша? В этой ситуации я должен отменить подписку и подписаться снова? я попытался возобновить поток, но это не сработало, поток был в неисправном состоянии ... любые идеи?

+0

Какая версия Орлеана работает? – Veksi

+0

Я использую версию 1.2 – YonatanBM

+0

Хм, есть несколько причин для этого, и я в настоящее время не хватает времени для устранения неполадок. Я думаю, что при появлении https://gitter.im/dotnet/orleans вы можете разблокировать вас быстрее. Затем вы можете вернуться и записать заметки здесь. Все в порядке, задавайте такие вопросы. :) – Veksi

ответ

2

Скорее всего, служба считывает события из eventhub быстрее, чем зерна обрабатывают их. EventHub может доставлять события со скоростью ~ 1 к/сек на каждый раздел. Последняя версия провайдера потока EventHub поддерживает противодавление, которое должно предотвратить эту проблему, но оно не было выпущено. Тем не менее, вы можете создавать собственные nugets.