CoreDurableSubscription sub = channelMapper.createDurableSubscription(topicName,
DurableSubscription sub = channelMapper.createDurableSubscription(topicName,
   public void testCreateGetRemoveDurableSubscription() throws Exception   {      String topicName = new GUID().toString();      String clientID = new GUID().toString();      String subscriptionName = new GUID().toString();      String selector = new GUID().toString();      ServerManagement.deployTopic(topicName);      CoreDurableSubscription sub = channelMapper.createDurableSubscription(topicName,                                                               clientID,                                                               subscriptionName,                                                               selector,                                                               false,                                                               ms, pm);      assertEquals(sub.getSelector(), selector);      CoreDurableSubscription sub_r = channelMapper.getDurableSubscription(clientID,                                                              subscriptionName,                                                              ms, pm);      assertEquals(sub_r.getSelector(), selector);      boolean removed = channelMapper.removeDurableSubscription(clientID, subscriptionName);      assertTrue(removed);      sub_r = channelMapper.getDurableSubscription(clientID, subscriptionName, ms, pm);      assertNull(sub_r);      removed = channelMapper.removeDurableSubscription(clientID, subscriptionName);      assertFalse(removed);   }