boolean validate(EntryEvent event, int cnt) {
      if (isSuspendValidation()) {
        return true;
      }
      passedValidation = false;
      assertEquals("Expected Call Count Assertion!", expectedCallCount, cnt);

      assertTrue(!event.getOperation().isExpiration());
      assertTrue(!event.getOperation().isNetLoad());
      assertEquals("isLoad Assertion!", isLoad(), event.getOperation().isLoad());
      assertEquals("isLocalLoad Assertion!", isLoad(), event.getOperation().isLocalLoad());
      assertTrue(!event.getOperation().isNetSearch());
      assertTrue(!event.isOriginRemote());
      assertNotNull(event.getRegion());
      assertNotNull(event.getRegion().getCache());
      assertNotNull(event.getRegion().getCache().getCacheTransactionManager());
      assertEquals(getTXId(), event.getTransactionId());

      if (!isPR()) {
        assertEquals("IsDistributed Assertion!", isDistributed(),
            event.getOperation().isDistributed());
      }
      assertEquals(getKey(), event.getKey());
      assertSame(getCallBackArg(), event.getCallbackArgument());
      if (newValIdentCheck) {
        assertSame(newVal, event.getNewValue());
      } else {
        assertEquals(newVal, event.getNewValue());
      }
      if (oldValIdentCheck) {
        assertSame(oldVal, event.getOldValue());
      } else {
        assertEquals(oldVal, event.getOldValue());
      }
      passedValidation = true;
      return true;
    }
EntryEvent, CallCount validator for callbacks (CacheWriter, CacheListener
geode-core/src/integrationTest/java/org/apache/geode/TXJUnitTest.java