Гость
Войти | Профиль | Очистить
Целевая тема:
Создать новую тему:
Автор:
Действия ...
Форумы / Java [игнор отключен] [закрыт для гостей] / транзакционная целостность при чтении из MQ через MQQueue / 1 сообщений из 1, страница 1 из 1
12.03.2013, 10:06:19
    #38180829
Tyo
Tyo
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
транзакционная целостность при чтении из MQ через MQQueue
Доброго времени суток. Подскажите плз, как добиться транзакционной целостности при приямом чтении из MQ через MQQueue. Из очереди читаю вот так:

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
MQQueueManager queueManager = null;
MQQueue queue = null;
try {
    MQEnvironment.hostname = ...;
    MQEnvironment.port     = ...;
    MQEnvironment.channel  = ...;			
    queueManager = new MQQueueManager(......);
    queue = queueManager.accessQueue(....,MQC.MQOO_INPUT_EXCLUSIVE);
    MQMessage mqMessage = new MQMessage();
    queue.get(mqMessage);
    queue.close();
    queueManager.disconnect();



После чего пишу что-то такое в БД. Хочется сделать так, чтобы сообщение исчезало из очереди только в том случае, если запись в БД прошла нормально. А в противном случае -- оставалось в очереди. При использовании стандартных компонентов jms на WAS этот вопрос решается автоматически при соотбтветствующих настройках, а как сделать вручную -- не соображу.

Заранее спасибо.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
Форумы / Java [игнор отключен] [закрыт для гостей] / транзакционная целостность при чтении из MQ через MQQueue / 1 сообщений из 1, страница 1 из 1
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение  
Полит. конфиден.  
созд. / загр.: 542ms
Закрыть
start [/forum/topic.php?fid=59&mobile=1&tid=2129803]:
 0ms
get settings:
 15ms
get forum list:
 26ms
check forum access:
 6ms
check topic access:
 6ms
track hit:
 81ms
get topic data:
 20ms
get forum data:
 5ms
get page messages:
 55ms
get tp. blocked users:
 2ms
others: 326ms
total:  542ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]