MessageProducer prod = sess.createProducer(queue);
MessageProducer prod = sessSend.createProducer(queue);
   public void testRedelMessageListener2() throws Exception   {      Connection conn = cf.createConnection();            conn.start();            Session sess = conn.createSession(true, Session.SESSION_TRANSACTED);            MessageConsumer cons = sess.createConsumer(queue);            RedelMessageListenerImpl listener = new RedelMessageListenerImpl(true);      listener.sess = sess;            cons.setMessageListener(listener);            MessageProducer prod = sess.createProducer(queue);      TextMessage m1 = sess.createTextMessage("a");      TextMessage m2 = sess.createTextMessage("b");      TextMessage m3 = sess.createTextMessage("c");            prod.send(m1);      prod.send(m2);      prod.send(m3);            sess.commit();                  listener.waitForMessages();            assertFalse(listener.failed);               }