Я использую ActiveMQ в качестве брокера для доставки сообщений. Эти сообщения предназначены для написания в dabatase. Иногда база данных недоступна или недоступна. В этом случае я хочу откатить свое сообщение, чтобы повторить попытку позже, и я...

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

TL; DR: мне нужно «воспроизвести» недоставленные сообщения обратно в их исходные очереди, как только я исправлю код потребителя, который изначально приводил к отклонению сообщений. Я настроил обмен недоставленными сообщениями (DLX) для RabbitMQ и...

private BrokerService createBroker() throws IOException, Exception { BrokerService broker = new BrokerService();KahaDBStore kaha=new KahaDBStore(); File file =new File(path); TransportConnector connector = new...

Например, мы хотим передать часть нашей информации стороннему API. Мы не можем полагаться на то, что этот API выйдет из строя, т. е. произойдет сетевая ошибка. Итак, у нас есть два варианта: Зарегистрируйте сбои запроса, отправленного в этот...

"errors.deadletterqueue.topic.name" работает с исходным разъемом? Я тестировал соединитель приемника JDBC и он работает, но я не нахожу запись с ошибкой сериализации, которая попадает в очередь недоставленных сообщений. Я использую Debezium...

У меня есть тема кафки HrEvents , которая содержит много сообщений Hire , Fire , Quit , Promotion и Demotion . Каждое сообщение о событии HR имеет свойство employee_id (также ключ, используемый для разделения) и свойство data , которое...

Я пытаюсь перенаправить подписку pubsub облачной функции в тему мертвой буквы, как описано здесь: https://cloud.google.com/pubsub/docs/dead-letter-topics#gcloud Я пытался $ gcloud pubsub subscriptions update gcf-worker-topic...

Я использую JMS Listener для чтения сообщения из темы Azure и обработки сообщения. После завершения процесса я возвращаюсь к другой теме. Я успешно выполнил функциональность с помощью весенней документации. Теперь мне нужно обработать сообщения об...

Мы настраиваем MassTransit для использования служебной шины Azure следующим образом: mtConfig.UsingAzureServiceBus((context, busConfig) => { busConfig.Host(new HostSettings...