new-integration-tests/src/test/java/oracle/weblogic/kubernetes/ItCoherenceTests.java
@Test
  @DisplayName("Create domain with a Coherence cluster using WDT and test rolling restart")
  @Slow
  @MustNotRunInParallel
  public void testCohernceServerRollingRestart() {
    final String successMarker = "CACHE-SUCCESS";

    // create a DomainHomeInImage image using WebLogic Image Tool
    String domImage = createAndVerifyDomainImage();

    // create and verify a WebLogic domain with a Coherence cluster
    createAndVerifyDomain(domImage);

    // build the Coherence proxy client program in the server pods
    // which load and verify the cache
    copyCohProxyClientAppToPods();

    // run the Coherence proxy client to load the cache
    String serverName = managedServerPrefix + "1";
    final ExecResult execResult1 = assertDoesNotThrow(
        () -> runCoherenceProxyClient(serverName, OP_CACHE_LOAD),
        String.format("Failed to call Coherence proxy client in pod %s, namespace %s",
            serverName, domainNamespace));

    assertAll("Check that the cache loaded successfully",
        () -> assertTrue(execResult1.exitValue() == 0, "Failed to load the cache"),
        () -> assertTrue(execResult1.stdout().contains(successMarker), "Failed to load the cache")
    );

    logger.info("Coherence proxy client {0} returns {1} \n ",
        OP_CACHE_LOAD, execResult1.stdout());

    // patch domain to rolling restart it by change restartVersion
    rollingRestartDomainAndVerify();

    // build the Coherence proxy client program in the server pods
    // which load and verify the cache
    copyCohProxyClientAppToPods();

    // run the Coherence proxy client to verify the cache contents
    final ExecResult execResult2 = assertDoesNotThrow(
        () -> runCoherenceProxyClient(serverName, OP_CACHE_VALIDATE),
        String.format("Failed to call Coherence proxy client in pod %s, namespace %s",
            serverName, domainNamespace));

    assertAll("Check that the cache loaded successfully",
        () -> assertTrue(execResult1.exitValue() == 0, "Failed to validate the cache"),
        () -> assertTrue(execResult2.stdout().contains(successMarker), "Failed to validate the cache")
    );

    logger.info("Coherence proxy client {0} returns {1}",
        OP_CACHE_VALIDATE, execResult2.stdout());

    logger.info("Coherence Server restarted in rolling fashion");
  }
/**
   * Create a WebLogic domain with a Coherence cluster and deploying it using WDT
   * Test rolling restart of Coherence managed servers and verify
   * that data are not lost during a domain restart.
   */
Create a WebLogic domain with a Coherence cluster and deploying it using WDT
Test rolling restart of Coherence managed servers and verify
that data are not lost during a domain restart.
Create a WebLogic domain with a Coherence cluster and deploying it using WDT Test rolling restart of Coherence managed servers and verify that data are not lost during a domain restart .
@Test
  @DisplayName("Create domain with a Coherence cluster using WDT and test rolling restart")
  @Slow
  @MustNotRunInParallel
  public void testCohernceServerRollingRestart() {
    final String successMarker = "CACHE-SUCCESS";
    String domImage = createAndVerifyDomainImage();
    createAndVerifyDomain(domImage);
    copyCohProxyClientAppToPods();
    String serverName = managedServerPrefix + "1";
    final ExecResult execResult1 = assertDoesNotThrow(
        () -> runCoherenceProxyClient(serverName, OP_CACHE_LOAD),
        String.format("Failed to call Coherence proxy client in pod %s, namespace %s",
            serverName, domainNamespace));
    assertAll("Check that the cache loaded successfully",
        () -> assertTrue(execResult1.exitValue() == 0, "Failed to load the cache"),
        () -> assertTrue(execResult1.stdout().contains(successMarker), "Failed to load the cache")
    );
    logger.info("Coherence proxy client {0} returns {1} \n ",
        OP_CACHE_LOAD, execResult1.stdout());
    rollingRestartDomainAndVerify();
    copyCohProxyClientAppToPods();
    final ExecResult execResult2 = assertDoesNotThrow(
        () -> runCoherenceProxyClient(serverName, OP_CACHE_VALIDATE),
        String.format("Failed to call Coherence proxy client in pod %s, namespace %s",
            serverName, domainNamespace));
    assertAll("Check that the cache loaded successfully",
        () -> assertTrue(execResult1.exitValue() == 0, "Failed to validate the cache"),
        () -> assertTrue(execResult2.stdout().contains(successMarker), "Failed to validate the cache")
    );
    logger.info("Coherence proxy client {0} returns {1}",
        OP_CACHE_VALIDATE, execResult2.stdout());
    logger.info("Coherence Server restarted in rolling fashion");
  }
@ Test @ DisplayName ( "Create domain with a Coherence cluster using WDT and test rolling restart" ) @ Slow @ MustNotRunInParallel public void testCohernceServerRollingRestart ( ) { final String successMarker = "CACHE-SUCCESS" ; String domImage = createAndVerifyDomainImage ( ) ; createAndVerifyDomain ( domImage ) ; copyCohProxyClientAppToPods ( ) ; String serverName = managedServerPrefix + "1" ; final ExecResult execResult1 = assertDoesNotThrow ( ( ) -> runCoherenceProxyClient ( serverName , OP_CACHE_LOAD ) , String . format ( "Failed to call Coherence proxy client in pod %s, namespace %s" , serverName , domainNamespace ) ) ; assertAll ( "Check that the cache loaded successfully" , ( ) -> assertTrue ( execResult1 . exitValue ( ) == 0 , "Failed to load the cache" ) , ( ) -> assertTrue ( execResult1 . stdout ( ) . contains ( successMarker ) , "Failed to load the cache" ) ) ; logger . info ( "Coherence proxy client {0} returns {1} \n " , OP_CACHE_LOAD , execResult1 . stdout ( ) ) ; rollingRestartDomainAndVerify ( ) ; copyCohProxyClientAppToPods ( ) ; final ExecResult execResult2 = assertDoesNotThrow ( ( ) -> runCoherenceProxyClient ( serverName , OP_CACHE_VALIDATE ) , String . format ( "Failed to call Coherence proxy client in pod %s, namespace %s" , serverName , domainNamespace ) ) ; assertAll ( "Check that the cache loaded successfully" , ( ) -> assertTrue ( execResult1 . exitValue ( ) == 0 , "Failed to validate the cache" ) , ( ) -> assertTrue ( execResult2 . stdout ( ) . contains ( successMarker ) , "Failed to validate the cache" ) ) ; logger . info ( "Coherence proxy client {0} returns {1}" , OP_CACHE_VALIDATE , execResult2 . stdout ( ) ) ; logger . info ( "Coherence Server restarted in rolling fashion" ) ; }
Create a WebLogic domain with a Coherence cluster and deploying it using WDT
 Test rolling restart of Coherence managed servers and verify
 that data are not lost during a domain restart.
Create a WebLogic domain with a Coherence cluster and deploying it using WDT Test rolling restart of Coherence managed servers and verify that data are not lost during a domain restart .
// create a DomainHomeInImage image using WebLogic Image Tool // create and verify a WebLogic domain with a Coherence cluster // build the Coherence proxy client program in the server pods // which load and verify the cache // run the Coherence proxy client to load the cache // patch domain to rolling restart it by change restartVersion // build the Coherence proxy client program in the server pods // which load and verify the cache // run the Coherence proxy client to verify the cache contents