**To Reproduce**
Steps to reproduce the behavior:
1. Go to '...'
2. Click on '....'
3. Scroll down to '....'
4. See error

**Expected behavior**
A clear and concise description of what you expected to happen.

**Screenshots**
If applicable, add screenshots to help explain your problem.

**Environment (please complete the following information):**
 - OS: [e.g. Windows 10]

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.job;

public abstract class JobExecutor {
    protected ShutdownListener shutdownListener;

    public abstract Object execute(String scriptType, String script);

    public void shutdown() {
        shutdownListener.onShutdown();
    }

    public void addShutdownListener(final ShutdownListener listener) {

    public static final int DCERPC_RESERVED_1      = 0x08;
    public static final int DCERPC_CONC_MPX        = 0x10; /* supports concurrent multiplexing */
    public static final int DCERPC_DID_NOT_EXECUTE = 0x20;
    public static final int DCERPC_MAYBE           = 0x40; /* `maybe' call semantics requested */
    public static final int DCERPC_OBJECT_UUID     = 0x80; /* if true, a non-nil object UUID */

import org.lastaflute.core.mail.Postbox;

public class PingSearchEngineJob {

    private static final Logger logger = LogManager.getLogger(PingSearchEngineJob.class);

    public String execute() {
        final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
        final FessConfig fessConfig = ComponentUtil.getFessConfig();

public class UpdateLabelJob {

    private static final Logger logger = LogManager.getLogger(UpdateLabelJob.class);

    protected QueryBuilder queryBuilder = null;

    public String execute() {
        final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
        final FessConfig fessConfig = ComponentUtil.getFessConfig();

        req.threshold(0); // always create tmp file

        // ## Act ##
        long before = countTmpFiles();
        logger.info("Before request. Number of temp files: " + before);
        req.execute(res -> {
            logger.info("Processing request. Number of temp files: " + countTmpFiles());
        }, e -> {});
        long after = countTmpFiles();

    @Override
    protected String getQueryClassName() {
        return FuzzyQuery.class.getSimpleName();
    }

    @Override
    public QueryBuilder execute(final QueryContext context, final Query query, final float boost) {
        if (query instanceof final FuzzyQuery fuzzyQuery) {
            if (logger.isDebugEnabled()) {
                logger.debug("{}:{}", query, boost);

    @Override
    protected String getQueryClassName() {
        return PhraseQuery.class.getSimpleName();
    }

    @Override
    public QueryBuilder execute(final QueryContext context, final Query query, final float boost) {
        if (query instanceof final PhraseQuery phraseQuery) {
            if (logger.isDebugEnabled()) {
                logger.debug("{}:{}", query, boost);

        int structureSize = SMBUtil.readInt2(buffer, bufferIndex);
        if ( structureSize != 4 ) {
            throw new SMBProtocolDecodingException("Expected structureSize = 4");
        }
        return 4;
    }

        final Field field = getClass().getField("STRING_DATA");
        assertThat(FieldUtil.getString(field), is(STRING_DATA));
    }

    /**
     * @throws Exception
     */
    @Test(expected = ClIllegalArgumentException.class)
    public void testSet() throws Exception {
        final Field field = getClass().getField("intField");
        FieldUtil.set(field, this, "abc");
    }

    /**