src/integration-test/java/software/amazon/cloudwatchlogs/emf/MetricsLoggerIntegrationTest.java [72:85]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void testMultipleFlushesOverTCP() throws InterruptedException {
        Environment env = new DefaultEnvironment(EnvironmentConfigurationProvider.getConfig());
        String metricName = "TCP-MultipleFlushes";
        int expectedSamples = 3;
        config.setAgentEndpoint("tcp://127.0.0.1:25888");

        logMetric(env, metricName);
        logMetric(env, metricName);
        Thread.sleep(500);
        logMetric(env, metricName);
        env.getSink().shutdown().join();

        assertTrue(retryUntilSucceed(() -> buildRequest(metricName), expectedSamples));
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/integration-test/java/software/amazon/cloudwatchlogs/emf/MetricsLoggerIntegrationTest.java [101:114]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void testMultipleFlushOverUDP() throws InterruptedException {
        Environment env = new DefaultEnvironment(EnvironmentConfigurationProvider.getConfig());
        String metricName = "UDP-MultipleFlush";
        int expectedSamples = 3;
        config.setAgentEndpoint("udp://127.0.0.1:25888");

        logMetric(env, metricName);
        logMetric(env, metricName);
        Thread.sleep(500);
        logMetric(env, metricName);
        env.getSink().shutdown().join();

        assertTrue(retryUntilSucceed(() -> buildRequest(metricName), expectedSamples));
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -