Описание тега dead-letter

Вопросы с тегом
1 ответ

Тупик в актерах Акка Скала

У меня очень простая структура, основанная на актерах Akka в Scala, но я продолжаю получать предупреждения о недоставленных сообщениях. Это код для основного класса, Collector - это отдельный класс, расширяющий Actor: object Executor extends App { c…
27 апр '14 в 19:03
1 ответ

RabbitMQ обмен сообщениями / очередь

Я не совсем понимаю обмен / очередь мертвых писем. онлайн-документ гласит: republished to another exchange when any of the following events occur: The message is rejected (basic.reject or basic.nack) with requeue=false, The TTL for the message expir…
09 окт '15 в 18:52
1 ответ

Лог-мертвые буквы Akka и мертвые буквы-журнала во время выключения не работают

Это простой вопрос, но он продолжает беспокоить меня и мои журналы. У меня есть конфиг: akka { log-dead-letters-during-shutdown = off log-dead-letters = off } Моя программа заканчивается akkaSystem.terminate() Я уверен, что конфиг загружен в систему…
03 фев '18 в 07:33
0 ответов

RabbitMQ - мертвые письма удаляются

Вот что у меня есть. QueueRoot: от DLX до ExchangeDelay1 QueueDelay1: TTL (x-message-ttl для очереди) от DLX до ExchangeDelay2 QueueDelay2: TTL (x-message-ttl для очереди) DLX в RootExchange Обмены разветвлены без ключей маршрутизации, связанных с с…
12 фев '19 в 11:34
1 ответ

Очередь мертвых писем в Camel против ActiveMQ?

Я использую EIP Dead Letter Channel точно так же, как описано в документах Camel для Dead Letter Channel. Вот мой camel.xml (заголовки удалены) <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring"> <!-- this is the Dead Le…
20 окт '13 в 19:42
1 ответ

Не удалось найти дескриптор свойства useOriginalBody в классе org.apache.camel.builder.DeadLetterChannelBuilder

Я пытаюсь использовать deadLetterChannelBuilder, но не могу найти правильные свойства для него. Кто-нибудь знает, кто они или где их найти? кажется, что тот, кто в документе, не работает.? Не удалось найти дескриптор свойства useOriginalBody в класс…
06 июн '18 в 20:19
2 ответа

Как работать с сообщениями в Dead Letter Queue

Мы используем WebLogic 10.3.6.0 и IBM MQ 7.5. Дизайн приложения заключается в отправке сообщений в очередь недоставленных сообщений (в WebLogic) при повторной доставке. Повторная доставка происходит, поскольку первая доставка не удалась из-за какой-…
11 дек '15 в 00:28
0 ответов

Лямбда не помещает сообщение в dlq

Я просто пытаюсь проверить свой DLQ на Lambda, и я не понимаю, почему сообщения не помещаются на него. Мой код просто делает 1 вещь throw new Exception("Test");, Первая ошибка была понятна, я пытался сделать это синхронно, используя кнопку Test, Пос…
04 окт '18 в 07:49
2 ответа

Чтение недоставленных сообщений из очереди служебной шины

Я хотел бы знать, возможно ли читать сообщения с недействительными сообщениями из очереди Azure Service Bus в JAVA. Я нашел следующий пример https://code.msdn.microsoft.com/windowsazure/Brokered-Messaging-Dead-22536dd8/sourcecode?fileId=123792&pathI…
08 июл '15 в 09:00
0 ответов

Сообщения, заканчивающиеся в очереди мертвых писем

У меня есть следующий код @Override public void onReceive(Object msg) throws Exception { if (msg instanceof newRequest) { ActorRef childRouter = getContext() .actorOf( new SmallestMailboxPool(actorPoolSize) .props(Props.create(ChildActor.class, para…
07 июн '18 в 18:19
1 ответ

Что произойдет после последней попытки с опциями повтора в долговременных функциях?

Я использую долговременную функцию, которая срабатывает из очереди. Я отправляю сообщения из очереди в довольно ненадежную службу, поэтому я настроил RetryPolicy. Тем не менее, я хотел бы видеть сообщения об ошибках, даже если максимальное количеств…
07 фев '19 в 19:41
0 ответов

Управление буклетами Azure с помощью сценариев powershell

Есть ли в PowerShell команды для управления тупиками подписки на темы. Я хочу написать сценарии PowerShell для загрузки всех тупиков или, возможно, для их повторения и повторного размещения на основе определенных критериев.
01 июл '14 в 13:48
1 ответ

Akka Remote Routing с использованием Java

Я пытаюсь реализовать базовый широковещательный маршрутизатор, в котором маршруты находятся на удаленных машинах. Код выглядит следующим образом: localApp.conf akka { log-dead-letters = 10 log-dead-letters-during-shutdown = off actor { provider = "a…
04 фев '14 в 11:39
1 ответ

Как использовать RepublishMessageRecoverer в Мертвых буквах?

У меня есть мертвые буквы для нескольких очередей, которые я использую. В конфигурации я использую: <bean id="retryAdvice" class="org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean"> <property name="message…
21 окт '14 в 13:24
1 ответ

akka 2.2.0 Scala 2.11 "сообщение не доставлено" - если только не используется Thread.sleep(50)

Я новичок в Scala и Akka, но у меня простой сценарий... Я пытаюсь получить список URL-адресов, отправляя каждый URL-адрес в виде сообщения новому субъекту, который отправит запрос http GET. Имея только список из 16 URL-адресов, я получаю около 40-65…
06 фев '14 в 23:43
0 ответов

Маршрут сообщений о переписке с обменом заголовками

Мне нравится направлять мои сообщения с мертвыми буквами в очереди dlx в соответствии с исходным именем очереди. Моя настройка: Сообщение мертвой буквы выглядит следующим образом { "payload_bytes": 44, "redelivered": true, "exchange": "dlx", "routin…
21 июн '16 в 16:56
3 ответа

Как удалить сообщение DeadLetter в разделе служебной шины Azure

Я пишу кусок кода, который позволит нам: Просмотр списка всех недоставленных сообщений, которые существуют в разделе служебной шины Azure (Peek) Исправить и отправить их обратно в тему Удалите их из очереди недоставленных писем после повторной отпра…
04 дек '13 в 14:41
1 ответ

Spring JMS и ActiveMQ, где можно увидеть сообщения в очереди недоставленных писем

Это моя конфигурация: @Bean ActiveMQConnectionFactory activeMQConnectionFactory() { String url = this.environment.getProperty("jms.broker.url"); ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); connectionFactory.setBrok…
25 янв '18 в 16:40
2 ответа

RabbitMQ, обмен мертвыми буквами -> Не можете направить сообщение на обмен по умолчанию?

С администратором RabbitMQ (v3) я попытался создать очередь, которая будет отправлять сообщения о недоставленных письмах в обмен по умолчанию, с ключом маршрутизации "MyErrorRoutingKey", к которому привязана очередь ошибок. Таким образом, в интерфей…
03 янв '13 в 15:31
1 ответ

Восстановление из очереди недоставленных писем

Я получаю все сообщения JMS из Queue1 все время и пытаюсь их обработать. Если я попытался обработать 5 раз и откатился 5 раз, я хочу, чтобы ActiveMQ поместил сообщение в другую очередь на некоторое время (например, 5 минут).Как я могу этого достичь?
23 апр '13 в 09:42