javax.jms.MessageConsumer zawiesza się na odbiór po zamknięciu konsumenta

Question

Zgodnie z javadoc, jeśli wywołasz metodę receive() na javax.jms.MessageConsumer, będzie ona blokować się w nieskończoność, dopóki nie zostanie wygenerowany komunikat lub dopóki użytkownik wiadomości nie zostanie zamknięty.

Mam wątek, w którym wywoływana jest funkcja receive(). W ramach zamykania wątku wywołuję metodę close(), ale konsola nadal blokuje funkcję receive(), dlatego wątek nie zostanie zamknięty. Istotą mojego kodu jest:

public String receiveMessage() { 
... 
... 
    System.out.println("About to receive") 
    TextMessage message = (TextMessage) consumer.receive(); 
    System.out.println("No longer receiving") 
... 
... 
} 

public void stop() { 
    try { 
     if (consumer != null) { 
      consumer.close(); 
     } 
    } catch (JMSException ex) { 
     throw new IllegalStateException(ex); 
    } 
} 

W debugerze widzę wywołanie metody close(), ale odbieranie bloków nadal. Jeśli użyję metody receive() z limitem czasu, będzie ona blokowana do momentu wygaśnięcia limitu czasu.

Wszystko wygląda dobrze dla mnie, mam nadzieję, że ktoś może mi powiedzieć, co robię źle.

Answer 1

Posortowałem problem, nie robiłem połączenia.start() w dowolnym miejscu. Kiedy już to wstawiłem, funkcja MessageConsumer.receive() przestała blokować, gdy ją zamknąłem i wszystko działało zgodnie z oczekiwaniami.

Dzięki za sugestie.

Answer 2

1. Spróbuj receive(long timeout), i nie zapomnij, aby sprawdzić, czy nie jest zwracana mesage null.
2. Oprócz consumer.close() możesz również przerwać wątek odpytywania - jeśli close() jest źle zaimplementowany i nie powiadamia zablokowanego odbiornika, spowoduje to jego wybudzenie.

Answer 3

Jeszcze jedna myśl.

W JMS połączenie jest wielowątkowe. Sesja i poniżej (konsument, producent, wiadomość itp.) are not thread-safe. Jeśli uzyskujesz dostęp do tego nieistotnego wątku z wielu wątków, odpowiadasz za unikanie dostępu wielowątkowego.

Poniższy kod wygląda tak, jak wywołujesz metody na Konsumencie z kilku wątków. Naruszenie tej zasady.

Bezpieczniejsze może być po prostu zamknięcie obiektu Connection. Żadne konflikty wątków i żadna rozsądna implementacja nie powinny czyścić odpowiednich zasobów w połączeniu.

Answer 4

Ale nadal wywoływanie consumer.close() w innym wątku nie jest właściwym rozwiązaniem. Będziesz musiał wykonać połączenie. Zamknij, które zajmie się zamknięciem wszystkich sesji, konsumentów, producentów itp. W ramach tego połączenia.