Гость
Целевая тема:
Создать новую тему:
Автор:
Форумы / Java [игнор отключен] [закрыт для гостей] / jmx queueSession.commit(); - help / 3 сообщений из 3, страница 1 из 1
27.06.2007, 17:16:03
    #34624162
GerdaS
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jmx queueSession.commit(); - help
есть такой метод :
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
 private  String getNewMessages(String clientId) {

	Context jndiContext =  null ;
	QueueConnectionFactory queueConnectionFactory =  null ;
	QueueConnection queueConnection =  null ;
	QueueSession queueSession =  null ;
	Queue queue =  null ;
	QueueReceiver queueReceiver =  null ;
	TextMessage message =  null ;
	Message m;
	String response;
	response =  new  String();
		
	 try  {
                jndiContext =  new  InitialContext();
                queueConnectionFactory = (QueueConnectionFactory)
			jndiContext.lookup("QueueConnectionFactory");
                queue = (Queue) jndiContext.lookup(clientId);
                queueConnection = queueConnectionFactory.createQueueConnection();
                queueSession = queueConnection.createQueueSession (true,Session.SESSION_TRANSACTED);
                queueReceiver = queueSession.createReceiver(queue);
	   queueConnection.start();
			
                 for (;;){
                      if (queueSession.getTransacted()){
                         m = queueReceiver.receive( 1000 );
                         queueSession.commit();
                         response =  mж
                                    
                }
        } catch  (Exception e) {
               e.printStackTrace();
        } finally  {
               if  (queueConnection !=  null ){
	       try  {
	           queueConnection.close();
                  } catch  (Exception e) {}
              }
        }
		

         return  response;
}

 на строке :
  queueSession.commit();

вылетает exc. :
javax.jms.TransactionInProgressException: Should not be call from a XASession

непонятно почему , может у кого было такое ? 

...
Рейтинг: 0 / 0
28.06.2007, 10:28:02
    #34625360
expp
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jmx queueSession.commit(); - help
смотриться как попытка закомитить сессию, которая входит в JTA транзакцию (тем более XA-txn), как сессию с локальной транзакцией. в корне неверно. почитайте JMS+JTA - очень интересно. сообщения лучше принимать MDB. JMS оооочень часто применяют не по назначению ....
...
Рейтинг: 0 / 0
28.06.2007, 14:05:32
    #34626104
GerdaS
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jmx queueSession.commit(); - help
exppсмотриться как попытка закомитить сессию, которая входит в JTA транзакцию (тем более XA-txn), как сессию с локальной транзакцией. в корне неверно. почитайте JMS+JTA - очень интересно. сообщения лучше принимать MDB. JMS оооочень часто применяют не по назначению ....

Спасибо, обязательно почитаю =)
...
Рейтинг: 0 / 0
Форумы / Java [игнор отключен] [закрыт для гостей] / jmx queueSession.commit(); - help / 3 сообщений из 3, страница 1 из 1
Найденые пользователи ...
Разблокировать пользователей ...
Читали форум (0):
Пользователи онлайн (0):
x
x
Закрыть


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