WebService, JMS, сообщения застревают в транзакции

@VorobyevEvgeny · Регистрация: 24.06.2013

Студворк — интернет-сервис помощи студентам

Добрый день. Такая вот проблема. Есть веб сервис, один из методов которого должен отправлять сообщения в очередь JMS. На другом компьютере развернут приложение смотрит на эту очередь и отвечает на сообщения.
Веб-сервис:

Java
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
@Stateless()
@WebService(serviceName = "Dev-test")
public class MessageSender {
    
    // BEGIN // JMS Block //
    
    @Resource(lookup = "ConnectionFactory")
    private ConnectionFactory connectionFactory;
    
    @Resource(lookup = "ServerQueue")
    private Destination serverQueue;
    
    Connection connection = null;
    
//    @PostConstruct
//    public void makeConnection() {
//        try {
//            connection = connectionFactory.createConnection();
//        } catch (Throwable t) {
//        }
//    }
//
//    @PreDestroy
//    public void endConnection() throws RuntimeException {
//        if (connection != null) {
//            try {
//                connection.close();
//            } catch (Exception e) {
//            }
//        }
//    }
    
    private String sendMessage(String message, String messageType) {
        String response = null;
        try {
            connection = connectionFactory.createConnection();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageProducer requestProducer = (MessageProducer) session.createProducer(serverQueue);
            TemporaryQueue replyQueue = session.createTemporaryQueue();
            MessageConsumer replyConsumer = session.createConsumer(replyQueue);
            
            connection.start();
        
            // Create message for sending
            TextMessage textMessage = session.createTextMessage();
            textMessage.setJMSType(messageType);
            textMessage.setText(message);
            textMessage.setJMSReplyTo(replyQueue);
            
            requestProducer.send(textMessage);
            
            Message messageFromReplyQueue = replyConsumer.receive();
            TextMessage textMessageFromReplyQueue = (TextMessage) messageFromReplyQueue;
            response = textMessageFromReplyQueue.getText();
        } catch (JMSException ex) { 
            
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (Exception e) {
            }
        }
        return response;
    }
}

Приложение на другой машине:

Java
1
2
3
4
5
6
7
8
9
10
@MessageDriven(mappedName = "ServerQueue")
public class SAMMessageConsumer implements MessageListener {
    @Resource(name = "ConnectionFactory")
    private ConnectionFactory connectionFactory;
 
    @Override
    public void onMessage(Message message) {
        //....
    }
}

Все бы хорошо, но все сообщения, отправленные из веб-сервиса попадают в "Held in Transaction" если верить браузеру очередей под названием QBrowser_light_V2.5.2.8.1_forJDK1.6 (см. атач).

Попробовал проделать все тоже самое, только на месте веб-сервиса развернул страницу JSP и сервлет. Вот код:

Java
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
53
54
55
56
57
58
59
@WebServlet(name = "MessageSender", urlPatterns = {"/MessageSender"})
public class MessageSender extends HttpServlet implements MessageListener {
    
    private Session session;
    private MessageProducer requestProducer;
    private MessageConsumer replyConsumer;
    
    @Resource(name = "ConnectionFactory")
    private ConnectionFactory connectionFactory;
    
    @Resource(name = "ServerQueue")
    private Destination serverQueue;
    
    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        String log = this.sendMessage(request.getParameter("message"));
        PrintWriter printWriter = response.getWriter();
        printWriter.print(log);
        printWriter.flush();
    }
    
    private String sendMessage (String message) {
        Connection connection = null;
        try {            
            connection = connectionFactory.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            
            requestProducer = (MessageProducer) session.createProducer(serverQueue);
                        
            TemporaryQueue replyQueue = session.createTemporaryQueue();
            replyConsumer = session.createConsumer(replyQueue);
            
            connection.start();
            
            // Create message for sending
            TextMessage textMessage = session.createTextMessage();
            textMessage.setJMSType(MessageType.GET_KEYS.toString());
            textMessage.setText(message);
            textMessage.setJMSReplyTo(replyQueue);
            
            requestProducer.send(textMessage);
                        
            Message messageFromReplyQueue = replyConsumer.receive();
            TextMessage textMessageFromReplyQueue = (TextMessage) messageFromReplyQueue;
                        
        } catch (JMSException ex) {
            Logger.getLogger(MessageSender.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            
        }
        return textMessageFromReplyQueue.getText();        
    }
 
    @Override
    public void onMessage(Message message) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }
}

И все прекрасно работает! Сообщения складываются в "Actual" (если опять же смотреть в браузер) и сразу поступают на обработку в приложение обработчика и успешно получает ответ. Есть какие-нибудь мысли по этому поводу?

@Skipy · 25.06.2013, 14:34

Сообщение от VorobyevEvgeny

Есть какие-нибудь мысли по этому поводу?

Ну, можно, например, не глотать исключения, а хотя бы выводить их в консоль. На осмысленную обработку надежд нет...

@VorobyevEvgeny · 25.06.2013, 16:44 **[ТС]**

@Skipy, Там нет исключений. Поток останавливается на строке Message messageFromReplyQueue = replyConsumer.receive(). На соседнем форуме мне подсказывают, что это может быть связанно с особенностью развертки в EJB, что там транзакции имеют некую особенность. replyConsumer.receive() - ожидает ответа от "обработчика сообщений", а сама транзакция "проходит" только в момент выхода из метода, который ее вызвал.

Добавлено через 1 час 23 минуты
Взлетело вот так:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
            //Вместо вот этого 
            //requestProducer.send(textMessage);
            //Пишем так
            this.send(requestProducer, textMessage);
 
    //И далее в классе так
    private void send (MessageProducer mp, TextMessage tm) {
        try {
            mp.send(tm);
        } catch (JMSException ex) {
            Logger.getLogger(class.getName()).log(Level.SEVERE, null, ex);
        }
    }

Новые блоги и статьи Все статьи Все блоги /
Новый ноутбук volvo 07.12.2025 Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro	Музыка, написанная Искусственным Интеллектом volvo 04.12.2025 Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .	От async/await к виртуальным потокам в Python IndentationError 23.11.2025 Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .	Поиск "дружественных имён" СОМ портов Argus19 22.11.2025 Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .	Сколько Государство потратило денег на меня, обеспечивая инсулином. Programma_Boinc 20.11.2025 Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha Etyuhibosecyu 20.11.2025 Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .	Мысли в слух kumehtar 18.11.2025 Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .	Создание Single Page Application на фреймах krapotkin 16.11.2025 Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .	Фото: Daniel Greenwood kumehtar 13.11.2025	Расскажи мне о Мире, бродяга kumehtar 12.11.2025 — Расскажи мне о Мире, бродяга, Ты же видел моря и метели. Как сменялись короны и стяги, Как эпохи стрелою летели. - Этот мир — это крылья и горы, Снег и пламя, любовь и тревоги, И бескрайние. . .