@Override
  public void process(DistributionMessage msg) {
    // TODO Auto-generated method stub
    if (msg instanceof FindDurableQueueReply) {
      FindDurableQueueReply reply = (FindDurableQueueReply) msg;
      synchronized (durableLocations) {
        // add me to the durable member set
        durableLocations.addAll(reply.getMatches());
      }
    }
    super.process(msg);
  }
A processor for helping a locator find the durable queues for a given durable client id. Asks
each cache server if they have the durable id and builds a list of matching servers.

@since GemFire 5.7
geode-core/src/main/java/org/apache/geode/internal/cache/FindDurableQueueProcessor.java