code: public ConsumerConnectionContext createConsumerConnectionContext(Endpoint endpoint, String messageSelector)
              throws JMSException {
          ConsumerConnectionContext context = new ConsumerConnectionContext();
          createOrReuseConnection(context, true);
          createSession(context);
          createDestination(context, endpoint);
          createConsumer(context, messageSelector);
          return context;
      }
docs: Creates a new consumer connection context, reusing any existing connection that might have
  already been created. The destination of the connection's session will be that of the given endpoint.
  The consumer will filter messages based on the given message selector expression (which may be
  null in which case the consumer will consume all messages).
  
  @param endpoint where the consumer will listen for messages
  @param messageSelector message consumer's message selector expression.
  @return the new consumer connection context fully populated
  @throws JMSException any error