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

        logMetric(env, metricName);
        env.getSink().shutdown().join();

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



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

        logMetric(env, metricName);
        env.getSink().shutdown().join();

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