public Set relayToListeners(Set cacheOpRecipients, Set adjunctRecipients,
      FilterRoutingInfo filterRoutingInfo, EntryEventImpl event, PartitionedRegion r,
      DirectReplyProcessor processor) {
    processorId = processor == null ? 0 : processor.getProcessorId();
    notificationOnly = true;

    setFilterInfo(filterRoutingInfo);
    Set failures1 = null;
    if (!adjunctRecipients.isEmpty()) {
      if (logger.isTraceEnabled(LogMarker.DM_VERBOSE)) {
        logger.trace(LogMarker.DM_VERBOSE,
            "Relaying partition message to other processes for listener notification");
      }
      resetRecipients();
      setRecipients(adjunctRecipients);
      failures1 = r.getDistributionManager().putOutgoing(this);
    }

    return failures1;
  }
relay this message to another set of recipients for event notification

@param cacheOpRecipients recipients of associated bucket CacheOperationMessage
@param adjunctRecipients recipients who unconditionally get the message
@param filterRoutingInfo routing information for all recipients
@param event the event causing this message
@param r the region being operated on
@param processor the reply processor to be notified
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/PartitionMessage.java