@Override
    public void process(DistributionMessage msg) {
      if (DistributionStats.enableClockStats) {
        start = DistributionStats.getStatTime();
      }
      if (msg instanceof DistTXRollbackReplyMessage) {
        DistTXRollbackReplyMessage reply = (DistTXRollbackReplyMessage) msg;
        // De-serialization needs to occur in the requesting thread, not a P2P
        // thread
        // (or some other limited resource)
        rollbackState = reply.getRollbackState();
      }
      super.process(msg);
    }
A processor to capture the value returned by {@link DistTXRollbackReplyMessage}
geode-core/src/main/java/org/apache/geode/internal/cache/DistTXRollbackMessage.java