code: @Override
  	protected final void remoteInit() throws JMSException
      {
          CreateDurableSubscriberQuery query = new CreateDurableSubscriberQuery();
          query.setSessionId(session.getId());
          query.setConsumerId(id);
          query.setTopic((Topic)destination);
          query.setMessageSelector(messageSelector);
          query.setNoLocal(noLocal);
          query.setName(subscriptionName);
          transportEndpoint.blockingRequest(query);
      }
docs: /*
  (non-Javadoc)
  @see net.timewalker.ffmq4.remote.session.RemoteMessageConsumer#remoteInit()