Package org.hibernate.search.exception.impl

Examples of org.hibernate.search.exception.impl.ErrorContextBuilder.allWorkToBeDone()


  }

  private void handleException(Exception e) {
    log.backendError( e );
    ErrorContextBuilder builder = new ErrorContextBuilder();
    builder.allWorkToBeDone( queue );
    builder.errorThatOccurred( e );
    resources.getErrorHandler().handle( builder.createErrorContext() );
  }

  /**
 
View Full Code Here


   */
  private void applyUpdates() throws InterruptedException, ExecutionException {
    AbstractWorkspaceImpl workspace = resources.getWorkspace();
   
    ErrorContextBuilder errorContextBuilder = new ErrorContextBuilder();
    errorContextBuilder.allWorkToBeDone( queue );
   
    IndexWriter indexWriter = workspace.getIndexWriter( errorContextBuilder );
    if ( indexWriter == null ) {
      log.cannotOpenIndexWriterCausePreviousError();
      return;
View Full Code Here

    if ( workOnWriter.isEmpty() ) {
      return;
    }
    log.debug( "Opening an IndexWriter for update" );
    ErrorContextBuilder errorContextBuilder = new ErrorContextBuilder();
    errorContextBuilder.allWorkToBeDone( workOnWriter );
    try {
      IndexWriter indexWriter = workspace.getIndexWriter( batchmode, errorContextBuilder );
      try {
        for ( LuceneWork lw : workOnWriter ) {
          lw.getWorkDelegate( worker ).performWork( lw, indexWriter );
View Full Code Here

    }
  }

  private void handleException(Exception e) {
    ErrorContextBuilder builder = new ErrorContextBuilder();
    builder.allWorkToBeDone( queue );
    builder.errorThatOccurred( e );
    resources.getErrorHandler().handle( builder.createErrorContext() );
  }

  /**
 
View Full Code Here

   */
  private void applyUpdates() throws InterruptedException, ExecutionException {
    AbstractWorkspaceImpl workspace = resources.getWorkspace();

    ErrorContextBuilder errorContextBuilder = new ErrorContextBuilder();
    errorContextBuilder.allWorkToBeDone( queue );

    IndexWriter indexWriter = workspace.getIndexWriter( errorContextBuilder );
    if ( indexWriter == null ) {
      log.cannotOpenIndexWriterCausePreviousError();
      return;
View Full Code Here

    if ( workOnWriter.isEmpty() ) {
      return;
    }
    log.debug( "Opening an IndexWriter for update" );
    ErrorContextBuilder builder = new ErrorContextBuilder();
    builder.allWorkToBeDone( workOnWriter );
    try {
      IndexWriter indexWriter = workspace.getIndexWriter( batchmode );
      try {
        for ( LuceneWork lw : workOnWriter ) {
          lw.getWorkDelegate( worker ).performWork( lw, indexWriter );
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.