runner.ensureYellow();
    }

    @AfterClass
    public static void afterClass() throws Exception {
        runner.close();
        runner.clean();
    }

    @Before
    public void before() throws Exception {
        runner.admin().indices().prepareDelete("_all").execute().actionGet();
        runner.refresh();

import org.dbflute.utflute.core.PlainTestCase;

public class RobotsTxtHelperTest extends PlainTestCase {
    public RobotsTxtHelper robotsTxtHelper;

    @Override
    protected void setUp() throws Exception {
        super.setUp();
        StandardCrawlerContainer container = new StandardCrawlerContainer().singleton("robotsTxtHelper", RobotsTxtHelper.class);
        robotsTxtHelper = container.getComponent("robotsTxtHelper");

     * @throws IOException Model read problem
     */
    @Test
    void testFlatUrls() throws IOException {
        testInheritance("flat-urls");
    }

    /**
     * MNG-5951 MNG-6059 child.x.y.inherit.append.path="false" test
     * @throws Exception
     */
    @Test
    void testNoAppendUrls() throws Exception {
        testInheritance("no-append-urls");
    }

  @Override
  protected void setUp() throws Exception {
    super.setUp();

    future = SettableFuture.create();
    tester = new ListenableFutureTester(future);
    tester.setUp();
  }

  public void testDefaultState() throws Exception {
    assertThrows(TimeoutException.class, () -> future.get(5, MILLISECONDS));
  }

  public void testSetValue() throws Exception {
    assertTrue(future.set("value"));

    @Nested
    @DisplayName("Artifact Extraction")
    class GAVExtractionTests {

        @Test
        @DisplayName("should extract Artifact from complete POM")
        void shouldExtractGAVFromCompletePOM() throws Exception {
            String pomXml = PomBuilder.create()
                    .groupId("com.example")
                    .artifactId("test-project")
                    .version("1.0.0")
                    .build();

  }

  @Test
  @Throws(Exception::class)
  fun timeDurationTruncatedToMaxValue() {
    val cacheControl =
      CacheControl
        .Builder()
        .maxAge(365 * 100, TimeUnit.DAYS) // Longer than Integer.MAX_VALUE seconds.
        .build()
    assertThat(cacheControl.maxAgeSeconds).isEqualTo(Int.MAX_VALUE)
  }

  @Test
  @Throws(Exception::class)
  fun secondsMustBeNonNegative() {

import java.io.StringReader;

import org.junit.Test;

/**
 * @author koichik
 */
public class LineIteratorTest {

    /**
     * @throws Exception
     */
    @Test
    public void test() throws Exception {
        final StringReader reader = new StringReader("aaa\nbbb\nccc\n");
        final LineIterator it = new LineIterator(reader);
        assertThat(it.hasNext(), is(true));

    @Deprecated
    Wagon getWagon(String protocol) throws UnsupportedProtocolException;

    @Deprecated
    Wagon getWagon(Repository repository) throws UnsupportedProtocolException, WagonConfigurationException;

    //
    // Retriever
    //
    void getArtifact(Artifact artifact, ArtifactRepository repository, TransferListener transferListener, boolean force)
            throws TransferFailedException, ResourceDoesNotExistException;

    /**
     * @throws Exception
     */
    @Test(expected = EmptyArgumentException.class)
    public void testForName_EmptyName() throws Exception {
        ClassUtil.forName("");
    }

    /**
     * @throws Exception
     */
    @Test(expected = EmptyArgumentException.class)
    public void testGetField_EmptyName() throws Exception {
        ClassUtil.getField(getClass(), "");
    }

   * writer each time it is called.
   *
   * <p>The caller is responsible for ensuring that the returned writer is closed.
   *
   * @throws IOException if an I/O error occurs while opening the writer
   */
  public abstract Writer openStream() throws IOException;

  /**
   * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not