Есть ли IBM MQ JAVA API для перемещения сообщений из одной очереди в другую?Перемещение сообщений между очередями
Я могу просматривать сообщения из очереди и размещать сообщения, используя Java API. Но я хочу переместить сообщение из одной очереди в другую. Не могли бы вы дать пример кода, если он есть?
Или нам нужно удалить сообщение из queue1, а затем отправить сообщение в queue2 для перемещения сообщений?
Вам нужно ПОЛУЧИТЬ из очереди 1, а затем выполнить PUT в очереди 2. Если вы просто просматриваете, есть вероятность, что до yoy GET это из очереди 1, потребитель уже использовал его с помощью GET. Вы можете найти пример кода для многих сценариев on this website.
Я столкнулся с той же проблемой, и после многих разочаровывающих часов я сделал это с помощью инструмента «MQJExplorer_v0.16». С помощью этого инструмента вы можете экспортировать/импортировать все сообщения (или одно сообщение) из одной очереди в другую.
Если у вас возникли проблемы при установке. Убедитесь, что вы используете правильную версию jdk (я столкнулся с той же проблемой). Вы можете проверить версию java в файле MetaInf одного из загруженных артефактов, убедитесь, что у вас есть одна и та же версия jdk или более новая на вашем локальном компьютере и просто установите JAVA_HOME в переменные окружения.
Если вы можете объяснить, почему вы хотите это сделать, тогда мы сможем ответить на него лучше ... Я говорю, потому что вы можете сделать источник Q передачей Q в MA –
Хорошо. В моем приложении Java полностью рассматриваются очереди. Сообщение будет перемещаться из одной очереди в другую, а весь поток контролируется таким образом. В случае возникновения проблем при обработке сообщений из очереди нам необходимо отправить сообщение в ОШИБКУ Очереди. Существует пользовательский интерфейс, с помощью которого мы можем просмотреть сообщение, помещенное в очередь ошибок. После того как обзор сообщения будет выполнен, пользователь может поставить его в очередь в исходную очередь, из которой было отправлено сообщение. Поэтому мне нужно использовать JAVA MQ API для желаемой функциональности. Я не контролирую конфигурацию очереди. Я просто имею список имен очередей, которые мы должны использовать – user1166031