eadCount); L53: for (int i = 0; i < threadCount; i++) { L54: executor.execute(() -> { L55: try { L56: drainQueue(); L57: } catch (Exception e) { L58: e.printStackTrace(); L59: } L60: }); L61: } L62: executor.shutdown(); L63: } L64: L65: private void drainQueue() throws Exception { L66: for (HttpUrl url; (url = queue.take()) != null; ) { L67: if (!fetchedUrls.add(url)) { L68: continue; L69: } L70: L71: Thread currentThread...

ost; L21:import org.codelibs.fess.unit.UnitFessTestCase; L22: L23:public class DuplicateHostHelperTest extends UnitFessTestCase { L24: private DuplicateHostHelper duplicateHostHelper; L25: L26: @Override L27: public void setUp() throws Exception { L28: super.setUp(); L29: duplicateHostHelper = new DuplicateHostHelper(); L30: duplicateHostHelper.duplicateHostList = new ArrayList<DuplicateHost>(); L31: L32: DuplicateHost foo = new DuplicateHost(); L33: f...

temHelper.getHostname()); L71: postcard.setClustername(ping.getClusterName()); L72: postcard.setClusterstatus(ping.getClusterStatus()); L73: }); L74: } catch (final Exception e) { L75: logger.warn("Failed to send a test mail.", e); L76: } finally { L77: SMailCallbackContext.clearPreparedMessageHookOnThread(); L78: } L79: } L80: ...

extends AbstractSetTester<E> { L46: L47: private SortedSet<E> sortedSet; L48: private List<E> values; L49: private @Nullable E a; L50: private @Nullable E b; L51: private @Nullable E c; L52: L53: @Override L54: public void setUp() throws Exception { L55: super.setUp(); L56: sortedSet = (SortedSet<E>) getSet(); L57: values = L58: copyToList( L59: getSubjectGenerator() L60: .getSampleElements(getSubjectGenerator().getCollectionSize().getNumElements()));...

assertFalse(future.isCancelled()); L97: L98: assertTrue(latch.await(5, SECONDS)); L99: assertTrue(future.isDone()); L100: assertFalse(future.isCancelled()); L101: L102: try { L103: future.get(); L104: fail("Future should rethrow the exception."); L105: } catch (ExecutionException e) { L106: assertThat(e).hasCauseThat().hasMessageThat().isEqualTo(message); L107: } L108: } L109:}...

getRelatedContent(form).ifPresent(entity -> { L188: try { L189: relatedContentService.store(entity); L190: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L191: } catch (final Exception e) { L192: logger.warn("Failed to process a request.", e); L193: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L194: this::asEditHtml);...

getBoostDocumentRule(form).ifPresent(entity -> { L188: try { L189: boostDocumentRuleService.store(entity); L190: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L191: } catch (final Exception e) { L192: logger.warn("Failed to process a request.", e); L193: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L194: this::asEditHtml);...

L424: L425: ImmutableMultimap(ImmutableMap<K, ? extends ImmutableCollection<V>> map, int size) { L426: this.map = map; L427: this.size = size; L428: } L429: L430: // mutators (not supported) L431: L432: /** L433: * Guaranteed to throw an exception and leave the multimap unmodified. L434: * L435: * @throws UnsupportedOperationException always L436: * @deprecated Unsupported operation. L437: */ L438: @CanIgnoreReturnValue L439: @Deprecated L440: @Override L441: @DoNotCall("Always...

src="${fe:url('/js/bootstrap.min.js')}"></script> L31: <script type="text/javascript" src="${fe:url('/js/suggestor.js')}"></script> L32: <script type="text/javascript" src="${fe:url('/js/search.js')}"></script> L33:</body> L34:</html> L35:<% }catch(Exception e){session.invalidate();} %>...

final SearchLogHelper searchLogHelper = ComponentUtil.getSearchLogHelper(); L29: L30: final StringBuilder resultBuf = new StringBuilder(); L31: L32: try { L33: searchLogHelper.storeSearchLog(); L34: } catch (final Exception e) { L35: logger.error("Failed to store a search log.", e); L36: resultBuf.append(e.getMessage()).append("\n"); L37: } L38: L39: return resultBuf.toString(); L40: } L41: L42:}...