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 ) ; }
Initialize the remote endpoint for this consumer