import java.util.List;
import java.util.Map;

import org.codelibs.fess.opensearch.user.exentity.Group;
import org.dbflute.Entity;
import org.dbflute.dbmeta.AbstractDBMeta;
import org.dbflute.dbmeta.info.ColumnInfo;
import org.dbflute.dbmeta.info.UniqueInfo;
import org.dbflute.dbmeta.name.TableSqlName;
import org.dbflute.dbmeta.property.PropertyGateway;
import org.dbflute.dbway.DBDef;
import org.dbflute.util.DfTypeUtil;

/**

        CloseableUtil.closeQuietly(in);
        logger.info(content);
        assertTrue(content.contains("テスト"));
    }

    public void test_getXml_entity() {
        final InputStream in = ResourceUtil.getResourceAsStream("extractor/test_entity.xml");
        final String content = xmlExtractor.getText(in, null).getContent();
        CloseableUtil.closeQuietly(in);
        logger.info(content);
        assertTrue(content.contains("テスト"));

            // Verify structure size
            assertEquals(41, SMBUtil.readInt2(buffer, 64));

            // Verify info type and file info class
            // setFileInfoClass sets the info type to SMB2_0_INFO_FILE (1)
            assertEquals(Smb2Constants.SMB2_0_INFO_FILE, buffer[66]);
            assertEquals((byte) 0x08, buffer[67]);

        long endOfFile = 1024L;
        FileEndOfFileInformation info = new FileEndOfFileInformation(endOfFile);

        assertNotNull(info);
        assertEquals(FileInformation.FILE_ENDOFFILE_INFO, info.getFileInformationLevel());

        // Verify through toString that value is set
        assertTrue(info.toString().contains("endOfFile=" + endOfFile));
    }

    @ParameterizedTest

    val delegate = delegate
    if (delegate != null) {
      this.delegate = null
      delegate.onMessage(webSocket, bytes)
    } else {
      events.add(Message(bytes = bytes))
    }
  }

  override fun onMessage(
    webSocket: WebSocket,
    text: String,
  ) {
    Platform.get().log("[WS $name] onMessage", Platform.INFO, null)
    val delegate = delegate

    response: Response,
  ) {
    get().log("[ES] onOpen", Platform.INFO, null)
    events.add(Open(eventSource, response))
    drainCancelQueue(eventSource)
  }

  override fun onEvent(
    eventSource: EventSource,
    id: String?,
    type: String?,
    data: String,
  ) {
    get().log("[ES] onEvent", Platform.INFO, null)
    events.add(Event(id, type, data))
    drainCancelQueue(eventSource)
  }

        this.enableJsonLogging = enable;
        log.info("JSON logging {}", enable ? "enabled" : "disabled");
    }

    /**
     * Enable or disable sensitive data masking
     *
     * @param enable true to enable masking
     */
    public void setSensitiveDataMaskingEnabled(boolean enable) {
        this.maskSensitiveData = enable;
        log.info("Sensitive data masking {}", enable ? "enabled" : "disabled");

    /**
     * Returns the geo info.
     *
     * @return The geo info.
     */
    public abstract GeoInfo getGeoInfo();

    /**
     * Returns the facet info.
     *
     * @return The facet info.
     */
    public abstract FacetInfo getFacetInfo();

    /**
     * Returns the highlight info.
     *
     * @return The highlight info.
     */

        // Access private field 'info'
        java.lang.reflect.Field infoField = Trans2QueryPathInformationResponse.class.getDeclaredField("info");
        infoField.setAccessible(true);
        Info info = (Info) infoField.get(trans);
        assertNotNull(info);
        assertEquals(attributes, info.getAttributes());
        assertEquals(create, info.getCreateTime());

import java.util.Map;

import org.codelibs.fess.opensearch.config.exentity.CrawlingInfo;
import org.dbflute.Entity;
import org.dbflute.dbmeta.AbstractDBMeta;
import org.dbflute.dbmeta.info.ColumnInfo;
import org.dbflute.dbmeta.info.UniqueInfo;
import org.dbflute.dbmeta.name.TableSqlName;
import org.dbflute.dbmeta.property.PropertyGateway;
import org.dbflute.dbway.DBDef;
import org.dbflute.util.DfTypeUtil;

/**