}
private CreateConsumerResponse processCreateDurableSubscriber( CreateDurableSubscriberQuery query ) throws JMSException
{
LocalSession session = lookupSession(query);
LocalDurableTopicSubscriber subscriber = (LocalDurableTopicSubscriber)session.createDurableSubscriber(query.getConsumerId(),
query.getTopic(),
query.getName(),
query.getMessageSelector(),
query.isNoLocal());