101102103104105106107108109110111
} assertNotNull("Expected response message", responseListener.resMessage); assertEquals(DOMUtils.parse(resMessage), DOMUtils.parse(responseListener.resMessage)); con.stop(); session.close(); con.close(); } public static class ResponseListener implements MessageListener
6566676869707172737475
Connection con = mock(QueueConnection.class); SingleConnectionFactory scf = new SingleConnectionFactory(con); QueueConnection con1 = scf.createQueueConnection(); con1.start(); con1.stop(); con1.close(); QueueConnection con2 = scf.createQueueConnection(); con2.start(); con2.stop(); con2.close();
6970717273747576777879
con1.start(); con1.stop(); con1.close(); QueueConnection con2 = scf.createQueueConnection(); con2.start(); con2.stop(); con2.close(); scf.destroy(); // should trigger actual close verify(con, times(2)).start(); verify(con, times(2)).stop();
8384858687888990
assert "Hi".equals(((TextMessage) message).getText()); consumer.close(); producer.close(); queueSession.close(); queueConnection.stop(); } }
8788899091929394
con.start(); MessageConsumer consumer = session.createConsumer(resQueue); TextMessage textMessage = (TextMessage)consumer.receive(TEST_RUN_TIME); String result = textMessage.getText(); assertTrue(result != null); con.stop(); } }
153154155156157158159160161162163
assertNotNull("Expected response message", responseListener.resMessage); assertEquals(DOMUtils.parse(resMessage), DOMUtils.parse(responseListener.resMessage)); receiver.close(); con.stop(); session.close(); con.close(); } public static class ResponseListener implements MessageListener
119120121122123124125126127128129
message.setJMSReplyTo(resQueue); QueueSender sender = session.createSender(reqQueue); sender.send(message); sender.close(); ps.println("Request message sent, doing something interesting in the mean time... ;-) "); con.stop(); } catch (Exception e) { e.printStackTrace(ps); }
109110111112113114115116117118119
919293949596979899100101
Thread.sleep(1000); } finally { try { conn.stop(); } catch (Exception ignore) { } try { session.close(); } catch (Exception ignore) {
104105106107108109110111112113114