Описание тега redismqserver

2 ответа

Каков рекомендуемый способ поставить в очередь сообщения "отложенного выполнения" через ServiceStack/Redis MQ?

Я хотел бы поставить в очередь сообщения для обработки только по истечении заданного промежутка времени (т. Е. Достигнута минимальная дата / время выполнения) и / или во время обработки сообщения отложить его выполнение до более поздней точки. вовре…
26 авг '13 в 18:43
1 ответ

Как обслуживать запросы Redis MQ, которые зависят от сеанса пользователя в пакете служб

Я искал лучший подход для решения следующего сценария. Мои конечные точки API в настоящее время используют переменные Usersession при обработке запроса. Это становится проблемой, когда нам приходится ставить запросы в очередь сообщений с помощью Red…
0 ответов

ServiceStack RedisMqServer интервал повторных попыток

Как установить интервал повторных попыток ServiceStack RedisMqServer? Я заметил, что есть свойство с именем KeepAliveRetryAfterMs, Я установил это на 10 секунд, это отрицательно повлияет на mq в любом случае? Кроме того, возможно ли увеличить интерв…
16 ноя '13 в 17:06
2 ответа

Реализация WebHooks с помощью ServiceStack

В настоящее время я работаю над сервисом REST, позволяющим контролировать и контролировать некоторые физические устройства. Соответствующий REST API в значительной степени основан на принципах и идеях, которые вы можете найти в следующей статье: " У…
23 авг '13 в 13:41
1 ответ

Как я могу добавить задержку обработки неудачных сообщений в ServiceStack Redis MQ

Есть ли простой способ заставить Servicetack подождать x секунд, прежде чем повторить попытку неисправного элемента MQ (используя Redis MQ). На данный момент он просто пытается 3 раза подряд без задержки.
1 ответ

Как заставить RedisMqServer подождать секунду, прежде чем повторить сообщение?

Похоже, что аргумент конструктора requestTimeOut в RedisMqServer не влияет на время между повторными попытками сообщения. Есть ли другой способ добавить задержку между повторными попытками сообщения? В частности, мы хотим добавить свойство к сообщен…
30 сен '13 в 18:58
1 ответ

Переопределить время видимости для сообщения в очереди [ServiceStack]

Для длительных запросов на основе сообщений мы можем установить тайм-аут видимости на уровне очереди, но, похоже, нет способа переопределить его на уровне сообщений. Я хотел бы иметь возможность продлить время для длительных операций, не устанавлива…
21 фев '19 в 00:59
1 ответ

Отложите освобождение сообщения до определенного времени, используя RedisMqHost

Можно ли использовать RedisMqServer в качестве простого планировщика задач? Например, чтобы опубликовать сообщение и выполнить его в функции (в определенное время)?
1 ответ

В поисках понимания ServiceStack.Redis: IRedisClient.PublishMessage vs IMessageQueueClient.Publish

Мне трудно разделить IRedisClient.PublishMessage а также IMessageQueueClient.Publish и понимаю, что я, должно быть, что-то путаю. ServiceStack дает нам возможность прослушивать трансляции pub/sub следующим образом: static IRedisSubscription _subscri…
0 ответов

ServiceStack.Mq: почему IRedisSubscription.OnMessage не запускается при добавлении данных в канал вручную?

Я использую ServiceStack и IRedisSubscriber. Я заставил его работать, запустив OnMessage. Однако иногда он не срабатывает, и я пытаюсь понять, почему. Базовая настройка: RedisClientManager = new PooledRedisClientManager("localhost:6379"); _mqServer …
0 ответов

получение указанной ниже ошибки после развертывания композита, связанного с MQSeries

Я новичок в этой концепции MQseriesAdapter, в среде клонирования создал MQSeriesAdapter с существующей настройкой конфигурации, указав имя jndi, имя канала, имя хоста, порт и имя администратора очередей и включив транзакции xa. после развертывания о…
21 сен '21 в 15:50
1 ответ

Пользовательское имя для списков RegisterHandler - RedisMqServer / IMessageQueueClient

Мы используем IMessageQueueClient, чтобы помещать сообщения в очередь Redis и забирать их с помощью метода registerhandler. https://docs.servicestack.net/redis-mq#redis Работает отлично, нареканий нет. Однако IMessageQueueClient.Publish() имеет пере…
19 ноя '21 в 18:39
0 ответов

Наше приложение, которое подключается к серверу MQ, внезапно теряет соединение и восстанавливается через более чем 2 часа, почему оно падает и 2-часовое окно

Это происходит довольно часто: наше приложение внезапно теряет соединение с сервером MQ (не знаю почему), и оно восстанавливается после более чем 2-часового окна (почему столько времени?). Любые конфигурации, которые нам нужно отключить для этого 2-…
0 ответов

Могли бы добавить нет. потоков в RedisMqServer приводят к дублированию обработки одного и того же сообщения?

Мы реализовали RedisMqServer библиотеки ServiceStack.Redis следующим образом: RedisMqServer _mqServer = new RedisMqServer(_redisManager, retryCount: 2); _mqServer.RegisterHandler<T>(base.ExecuteMessage, 4); _mqServer.Start(); Где 4 - нет. ните…
20 сен '23 в 09:15