private void initialize(SearchLoadAndWriteProcessor processor, String theRegionName,
        Object theKey, boolean multicast, int theTimeoutMs, int theTtl, int theIdleTime) {
      processorId = processor.processorId;
      regionName = theRegionName;
      setMulticast(multicast);
      key = theKey;
      timeoutMs = theTimeoutMs;
      ttl = theTtl;
      idleTime = theIdleTime;
      Assert.assertTrue(processor.region.getScope().isDistributed());
    }
Using a new or pooled message instance, create and send the query to all nodes.
geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java