@Override
    public void execute(Runnable runnable) {
      assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
      runnable.run();
    }

    @Override
    public void shutdown() {}

    @Override
    public List<Runnable> shutdownNow() {
      return ImmutableList.of();
    }

    @Override
    public boolean isShutdown() {
      return false;
    }

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNull;

import org.junit.Test;

public class QueryLogTest {

    @Test
    public void test_constructor() throws Exception {
        QueryLog queryLog = new QueryLog("test query", "test filter");

        assertNotNull(queryLog);

 * authentication tag.
 *
 * @author mbechler
 */
public class Smb2TransformHeader implements Encodable {

    /**
     * Transform header protocol identifier: 0xFD534D42 (0xFD 'S' 'M' 'B')
     */
    public static final int TRANSFORM_PROTOCOL_ID = 0xFD534D42;

    /**
     * Size of the transform header in bytes
     */
    public static final int TRANSFORM_HEADER_SIZE = 52;

        }

        public static Descriptor of(TestDescriptor d) {
            return new Descriptor(d.getName(), d.getClassName(), d.getParent() == null ? null : d.getParent().toString());
        }

        public String getClassName() {
            return className;
        }

        public String getFullName() {
            return className + "." + name;
        }

        @Override

import org.lastaflute.di.naming.NamingConvention;

/**
 * The creator of pager.
 *
 * @author shinsuke
 */
public class PagerCreator extends ComponentCreatorImpl {
    public static final String SUFFIX = "Pager";

    public PagerCreator(final NamingConvention namingConvention) {
        super(namingConvention);
        setNameSuffix(SUFFIX);
        setInstanceDef(InstanceDefFactory.SESSION);

 *
 * @author Colin Decker
 */
@NullUnmarked
public class TestCharSource extends CharSource implements TestStreamSupplier {

  private final TestByteSource byteSource;

  public TestCharSource(String content, TestOption... options) {
    this.byteSource = new TestByteSource(content.getBytes(UTF_8), options);
  }

  @Override
  public boolean wasStreamOpened() {
    return byteSource.wasStreamOpened();
  }

 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *

 *
 * @since 4.0.0
 */
@Experimental
public class MavenException extends RuntimeException {

    public MavenException() {}

    public MavenException(String message) {
        super(message);
    }

    public MavenException(String message, Throwable cause) {
        super(message, cause);
    }

    public MavenException(Throwable cause) {
        super(cause);
    }

        }

        public String getAppCipherAlgorithm() {
            return get(FessConfig.APP_CIPHER_ALGORITHM);
        }

        public String getAppCipherKey() {
            return get(FessConfig.APP_CIPHER_KEY);
        }

        public String getAppDigestAlgorithm() {
            return get(FessConfig.APP_DIGEST_ALGORITHM);
        }

        public String getAppEncryptPropertyPattern() {

import org.codelibs.fess.unit.UnitFessTestCase;

public class StorageTypeTest extends UnitFessTestCase {

    public void test_enumValues() {
        final StorageType[] types = StorageType.values();
        assertNotNull(types);
        assertEquals(3, types.length);
    }

    public void test_s3Type() {
        assertEquals(StorageType.S3, StorageType.valueOf("S3"));
    }

    public void test_gcsType() {