private void setIfTransactionDistributed(ReplyProcessor21 processor) {
    if (processor != null) {
      DistributionManager distributionManager = processor.getDistributionManager();
      if (distributionManager != null) {
        InternalCache cache = distributionManager.getCache();
        if (cache != null && cache.getTxManager() != null) {
          isTransactionDistributed = cache.getTxManager().isDistributed();
        }
      }
    }
  }
Waits for the response from the {@link RemoteOperationMessage}'s recipient

@throws RemoteOperationException if the member we waited for a response from departed
@throws RemoteOperationException if a response was required and not received
@throws RemoteOperationException if the ReplyException was caused by a
        RemoteOperationException
@throws RemoteOperationException if the remote side's cache was closed
geode-core/src/main/java/org/apache/geode/internal/cache/tx/RemoteOperationMessage.java