code: protected void remoteInit() throws JMSException
      {
          CreateConsumerQuery query = new CreateConsumerQuery();
          query.setConsumerId(id);
          query.setSessionId(session.getId());
          query.setDestination(destination);
          query.setMessageSelector(messageSelector);
          query.setNoLocal(noLocal);
          transportEndpoint.blockingRequest(query);        
      }
docs: Initialize the remote endpoint for this consumer