TermQuery termQuery3 = new TermQuery(new Term("field3", "value3"));

        boolQueryBuilder.add(termQuery1, BooleanClause.Occur.MUST);
        boolQueryBuilder.add(termQuery2, BooleanClause.Occur.SHOULD);
        boolQueryBuilder.add(termQuery3, BooleanClause.Occur.MUST_NOT);
        BooleanQuery booleanQuery = boolQueryBuilder.build();

        QueryContext context = new QueryContext("test", false);

        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);

 * request body start and end events occur within the response header events. Similarly,
 * [duplex calls][RequestBody.isDuplex] interleave the request and response bodies.
 *
 * Since connections may be reused, the proxy selection, DNS, and connect events may not be present
 * for a call. In future releases of OkHttp these events may also occur concurrently to permit
 * multiple routes to be attempted simultaneously.
 *

     * State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called the first
     * time.
     */
    public void starting() {}

    /**
     * Called when the service transitions from {@linkplain State#STARTING STARTING} to {@linkplain
     * State#RUNNING RUNNING}. This occurs when a service has successfully started.
     */
    public void running() {}

     * State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called the first
     * time.
     */
    public void starting() {}

    /**
     * Called when the service transitions from {@linkplain State#STARTING STARTING} to {@linkplain
     * State#RUNNING RUNNING}. This occurs when a service has successfully started.
     */
    public void running() {}

        } catch (JobProcessingException e) {
            assertTrue(e.getMessage().contains("Thumbnail Process terminated."));
        } catch (NullPointerException e) {
            // May occur if ServletContext is not fully initialized
            // This is acceptable in test environment
        }
    }

    // Test executeThumbnailGenerator with timeout

     *
     * @param paramMap the data store parameters
     * @param dataMap the document data to store
     * @throws DataStoreException if required fields are missing or other errors occur
     */
    @Override
    public void store(final DataStoreParams paramMap, final Map<String, Object> dataMap) {
        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();

      readHeader()
      if (!isControlFrame) {
        break
      }
      readControlFrame()
    }
  }

  /**
   * Reads a message body into across one or more frames. Control frames that occur between
   * fragments will be processed. If the message payload is masked this will unmask as it's being
   * processed.
   */
  @Throws(IOException::class)
  private fun readMessage() {
    while (true) {

   * colliding threads.  Because search is random, and collisions
   * only become known via CAS failures, convergence can be slow,
   * and because threads are typically not bound to CPUS forever,
   * may not occur at all. However, despite these limitations,
   * observed contention rates are typically low in these cases.
   *
   * It is possible for a Cell to become unused when threads that

   * {@code directExecutor} functions should avoid heavyweight operations inside {@code
   * AsyncFunction.apply}. Any heavyweight operations should occur in other threads responsible for
   * completing the returned {@code Future}.)
   *
   * <p>This method is similar to {@link java.util.concurrent.CompletableFuture#exceptionally}. It