} L44: return indexName; L45: } L46: L47: @Override L48: public OptionalEntity<ScheduledJob> selectByPK(final String id) { L49: Exception lastException = null; L50: for (int i = 0; i < 30; i++) { L51: try { L52: return super.selectByPK(id); L53: } catch (final Exception e) { L54: if (logger.isDebugEnabled()) { L55: logger.debug("Failed to select a job by {}", id, e); L56: } L57:...

); L35: } L36: L37: public void testSuccessfulNull() throws ExecutionException { L38: assertThat(getDone(Futures.<@Nullable String>immediateFuture(null))).isEqualTo(null); L39: } L40: L41: public void testFailed() { L42: Exception failureCause = new Exception(); L43: ExecutionException expected = L44: assertThrows(ExecutionException.class, () -> getDone(immediateFailedFuture(failureCause))); L45: assertThat(expected).hasCauseThat().isEqualTo(failureCause); L46: } L47: L48:...

org.codelibs.fess.app.web.base.login.SamlCredential; L33:import org.codelibs.fess.app.web.base.login.SamlCredential.SamlUser; L34:import org.codelibs.fess.crawler.Constants; L35:import org.codelibs.fess.exception.SsoLoginException; L36:import org.codelibs.fess.exception.SsoMessageException; L37:import org.codelibs.fess.exception.SsoProcessException; L38:import org.codelibs.fess.mylasta.action.FessUserBean; L39:import org.codelibs.fess.sso.SsoAuthenticator; L40:import org.codelibs.fess.sso.SsoResponseType; L41:import...

headerList = new ArrayList<>(); L171: } L172: headerList.add(new String[] { key, value }); L173: return this; L174: } L175: L176: public void connect(final Consumer<HttpURLConnection> actionListener, final Consumer<Exception> exceptionListener) { L177: final Runnable task = () -> { L178: if (paramList != null) { L179: char sp; L180: if (url.indexOf('?') == -1) { L181: sp = '?'; L182: }...

t; L31:import org.dbflute.optional.OptionalThing; L32: L33:public class RankFusionProcessorTest extends UnitFessTestCase { L34: L35: private static final String ID_FIELD = "_id"; L36: L37: public void test_default_1000docs_10size() throws Exception { L38: String query = "*"; L39: int allRecordCount = 1000; L40: int pageSize = 10; L41: try (RankFusionProcessor rankFusionProcessor = new RankFusionProcessor()) { L42: rankFusionProcessor.setSeacher(new Te...

tests: HTTP specified GMT, so we set it to L34: // something else. L35: TimeZone.setDefault(TimeZone.getTimeZone("America/Los_Angeles")) L36: } L37: L38: @AfterEach L39: @Throws(Exception::class) L40: fun tearDown() { L41: TimeZone.setDefault(originalDefault) L42: } L43: L44: @Test L45: @Throws(Exception::class) L46: fun parseStandardFormats() { L47: // RFC 822, updated by RFC 1123 with GMT. L48: assertThat("Thu, 01 Jan 1970 00:00:00 GMT".toHttpDateOrNull()!!.time).isEqualTo(0L)...

and limitations under L12: * the License. L13: */ L14: L15:package com.google.common.eventbus; L16: L17:import static com.google.common.base.Preconditions.checkNotNull; L18: L19:import java.lang.reflect.Method; L20: L21:/** L22: * Context for an exception thrown by a subscriber. L23: * L24: * @since 16.0 L25: */ L26:@ElementTypesAreNonnullByDefault L27:public class SubscriberExceptionContext { L28: private final EventBus eventBus; L29: private final Object event; L30: private final Object subscriber;...

try { L310: final byte[] buf = new byte[1024]; L311: while ((is.read(buf)) != -1) {} L312: } catch (final Exception ignored) {} finally { L313: try { L314: is.close(); L315: } catch (final Exception ignored) {} L316: } L317: } catch (final Exception ignored) {} L318: } L319: L320: protected void handleFileUploadException(final FileUploadException e) throws ServletException { L321: ...

ckage")); L35: assertEquals("java.util", Reflection.getPackageName(Map.Entry.class)); L36: } L37: L38: public void testNewProxy() throws Exception { L39: Runnable runnable = Reflection.newProxy(Runnable.class, X_RETURNER); L40: assertEquals("x", runnable.toString()); L41: } L42: L43: public void testNewProxyCantWorkOnAClass() throws Exception { L44: assertThrows( L45: IllegalArgumentException.class, () -> Reflection.newProxy(Object.class, X_RETURNER)); L46: } L47: L48: private...

ultList; L39:import org.codelibs.fess.es.client.SearchEngineClient; L40:import org.codelibs.fess.es.log.exbhv.ClickLogBhv; L41:import org.codelibs.fess.es.log.exbhv.FavoriteLogBhv; L42:import org.codelibs.fess.exception.ContainerNotAvailableException; L43:import org.codelibs.fess.exception.FessSystemException; L44:import org.codelibs.fess.helper.IndexingHelper; L45:import org.codelibs.fess.helper.IntervalControlHelper; L46:import org.codelibs.fess.helper.SearchLogHelper; L47:import org.codelibs....