Перемещение сообщений между очередями

Существует ли API JAVA IBM MQ для перемещения сообщений из одной очереди в другую?

Я могу просматривать сообщения из очереди и помещать сообщения, используя API Java. Но я хочу переместить сообщение из одной очереди в другую. Не могли бы вы привести пример кода, если он есть?

Или нам нужно удалить сообщение из очереди queue1, а затем поместить сообщение в queue2 для перемещения сообщений?


java ibm-mq
person user1166031    schedule 24.01.2012    source источник
comment
Если вы можете объяснить, почему вы хотите это сделать, тогда мы сможем ответить на него лучше... Я говорю, потому что вы можете сделать источник Q передачей Q в MA.   -  person Aravind Yarram    schedule 24.01.2012
comment
В порядке. Мое Java-приложение полностью работает с очередями. Сообщение перемещалось из одной очереди в другую, и таким образом контролировался весь поток. В случае каких-либо проблем при обработке сообщений из очереди нам необходимо поместить сообщение в Очередь ОШИБОК. Существует пользовательский интерфейс, с помощью которого мы можем просмотреть сообщение, помещенное в очередь ошибок. После просмотра сообщения пользователь может поставить его в исходную очередь, из которой сообщение было удалено из очереди. Следовательно, мне нужно использовать API-интерфейсы JAVA MQ для желаемой функциональности. У меня нет контроля над конфигурацией очереди. У меня просто есть список имен очередей, которые мы должны использовать   -  person user1166031    schedule 24.01.2012

Ответы (2)


arrow_upward
1
arrow_downward

Вам нужно ПОЛУЧИТЬ из очереди 1, а затем выполнить ПОЛОЖЕНИЕ в очереди 2. Если вы просто просматриваете, есть вероятность, что до того, как вы ПОЛУЧИТЕ его из очереди 1, потребитель уже использовал его, используя ПОЛУЧИТЬ. Вы можете найти примеры кода для многих сценариев на этом веб-сайте.

person Aravind Yarram    schedule 24.01.2012

arrow_upward
0
arrow_downward

Я столкнулся с той же проблемой, и после многих разочаровывающих часов я сделал это с помощью инструмента «MQJExplorer_v0.16». С помощью этого инструмента вы можете экспортировать/импортировать все сообщения (или одно сообщение) из одной очереди в другую.

Если у вас возникли проблемы при установке. Пожалуйста, убедитесь, что вы используете правильную версию jdk (я столкнулся с той же проблемой). Вы можете проверить версию java в файле MetaInf одного из загруженных артефактов, убедиться, что на вашем локальном компьютере установлена ​​такая же версия jdk или более новая, и просто установить JAVA_HOME в переменных среды.

person user5173252    schedule 27.10.2015