cons = sess.createConsumer(dest, selector, noLocal);
if (subName == null) { cons = sess.createConsumer(dest, selector, noLocal); } else { cons = sess.createDurableSubscriber((Topic)dest, subName, selector, noLocal); }
      public void init()      {         try         {            Connection conn = getNextConnection();                        sess = conn.createSession(transacted, ackMode);                       cons = sess.createConsumer(dest, selector, noLocal);                            }         catch (Exception e)         {            log.error("Receiver failed", e);            failed = true;         }           }