cons = sess.createConsumerDelegate(dest, messageSelector, false, subName);
cons = sess.createConsumerDelegate(dest, messageSelector, false, subName, true);
   public JBossConnectionConsumer(ConnectionDelegate conn, Destination dest,                                   String subName, String messageSelector,                                  ServerSessionPool sessPool, int maxMessages) throws JMSException   {      trace = log.isTraceEnabled();            //this.connection = conn;      this.destination = dest;      this.serverSessionPool = sessPool;      this.maxMessages = maxMessages;      if (this.maxMessages < 1)         this.maxMessages = 1;      //Create a consumer - we must create with CLIENT_ACKNOWLEDGE - they get must not get acked      //via this session!      sess = conn.createSessionDelegate(false, Session.CLIENT_ACKNOWLEDGE, false);      cons = sess.createConsumerDelegate(dest, messageSelector, false, subName);      receiverID = cons.getReceiverID();      id = threadId.increment();      internalThread = new Thread(this, "Connection Consumer for dest " + destination + " id=" + id);      internalThread.start();      if (trace) { log.trace("New " + this); }   }