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

  /**
   * Opens a new buffered {@link InputStream} for reading from this source. The returned stream is

        boolBuilder.add(new TermQuery(new Term("title", "fess")), BooleanClause.Occur.MUST);
        boolBuilder.add(new PrefixQuery(new Term("content", "search")), BooleanClause.Occur.SHOULD);
        boolBuilder.add(new WildcardQuery(new Term("url", "*.html")), BooleanClause.Occur.MUST_NOT);
        BooleanQuery boolQuery = boolBuilder.build();
        BoostQuery boostQuery = new BoostQuery(boolQuery, 5.5f);

            }
        }
    }

    /**
     * Closes the underlying CrawlerClient and releases any resources associated with it.
     *
     * @throws Exception if an error occurs during the close operation
     */
    @Override
    public void close() throws Exception {
        client.close();
    }

    /**
     * Returns the underlying CrawlerClient.

     *
     * @param field the field (must not be {@literal null})
     * @return the field value
     * @throws IllegalAccessRuntimeException {@link IllegalAccessException} if an error occurs
     * @see #getInt(Field, Object)
     */
    public static int getInt(final Field field) throws IllegalAccessRuntimeException {
        assertArgumentNotNull("field", field);

        return getInt(field, null);

 * </ul>
 *
 * <p>Logging:</p>
 * <ul>
 *   <li>Logs a warning if the clientConnectionManager is null.</li>
 *   <li>Logs a warning if an exception occurs during connection monitoring.</li>
 * </ul>
 *
 */
public class Hc5ConnectionMonitorTarget implements TimeoutTarget {
    private static final Logger logger = LogManager.getLogger(Hc5ConnectionMonitorTarget.class);

     * @param req the HTTP servlet request
     * @param resp the HTTP servlet response
     * @param file the SMB file to download
     * @throws IOException if an I/O error occurs
     */
    protected void doFile(final HttpServletRequest req, final HttpServletResponse resp, final SmbFile file) throws IOException {
        final byte[] buf = new byte[8192];
        String url, type;
        int n;

    /**
     * The headers of the response.
     */
    private Map<String, List<String>> headers;

    /**
     * Closes the content cache if it is not null.
     *
     * @throws IOException if an I/O error occurs.
     */
    @Override
    public void close() throws IOException {
        if (contentCache != null) {
            contentCache.close();
        }
    }

    /**

 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.repository.legacy;

import org.apache.maven.wagon.TransferFailedException;

/**
 * Occurs when a download checksum fails.
 *
 */
@Deprecated
public class ChecksumFailedException extends TransferFailedException {
    public ChecksumFailedException(String s) {
        super(s);
    }

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

/**
 * This exception is thrown when an error occurs during OpenSearch access.
 *
 * @author shinsuke
 *
 */
public class OpenSearchAccessException extends CrawlerSystemException {

    private static final long serialVersionUID = 1L;

    /**

        assertThrows(ClassCastException.class, () -> sid.unwrap(String.class));
    }

    /**
     * Test the resolve method.
     *
     * @throws IOException if an I/O error occurs
     */
    @Test
    void testResolve() throws IOException {
        CIFSContext mockContext = mock(CIFSContext.class);
        SidResolver mockResolver = mock(SidResolver.class);