public void beforeProcessMessage(ClusterDistributionManager dm, DistributionMessage message) {
      if (message instanceof DeposePrimaryBucketMessage) {
        logger.info(
            "TestDistributionMessageObserver.beforeProcessMessage about to signal received_deposePrimaryMessage gate");
        blackboard.signalGate(DEPOSE_PRIMARY_MESSAGE_RECEIVED);
        logger.info(
            "TestDistributionMessageObserver.beforeProcessMessage done signal received_deposePrimaryMessage gate");
      } else if (message instanceof DLockReleaseProcessor.DLockReleaseReplyMessage
          && blackboard.isGateSignaled(DEPOSE_PRIMARY_MESSAGE_RECEIVED)) {
        try {
          logger.info(
              "TestDistributionMessageObserver.beforeSendMessage about to signal on continue_put_op");
          blackboard.signalGate(CONTINUE_PUT_OP);

          logger.info(
              "TestDistributionMessageObserver.beforeSendMessage waits for signal on "
                  + CONTINUE_DEPOSE_PRIMARY);
          blackboard.waitForGate(CONTINUE_DEPOSE_PRIMARY);
          logger.info(
              "TestDistributionMessageObserver.beforeSendMessage done wait for signal on "
                  + CONTINUE_DEPOSE_PRIMARY);
        } catch (Exception e) {
          throw new RuntimeException(e);
        }
      }
    }
This test is disabled as it is not guaranteed to pass it everytime. This test is related to the
conflation in batch. yet did find any way to ascertain that the vents in the batch will always
be conflated.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANConflationDistributedTest.java