which L111: * should cause {@link #run()} to return. L112: */ L113: protected abstract void run() throws Exception; L114: L115: /** L116: * Stop the service. This method is invoked on the execution thread. L117: * L118: * <p>By default this method does nothing. L119: */ L120: // TODO: consider supporting a TearDownTestCase-like API L121: protected void shutDown() throws Exception {} L122: L123: /** L124: * Invoked to request the service to stop. L125: * L126: * <p>By default this...

@GwtIncompatible // serialization L122: private static void reserializeAndAssert(Object object) throws Exception { L123: Object copy = reserialize(object); L124: assertEquals(object, copy); L125: assertEquals(object.getClass(), copy.getClass()); L126: } L127: L128: @J2ktIncompatible L129: @GwtIncompatible // serialization L130: private static Object reserialize(Object object) throws Exception { L131: ByteArrayOutputStream bytes = new ByteArrayOutputStream(); L132: new ObjectOutputSt...

L31: * L32: * @author Nishant Thakkar L33: * @author Sven Mawson L34: */ L35:public class ExecutionListTest extends TestCase { L36: L37: private final ExecutionList list = new ExecutionList(); L38: L39: public void testRunOnPopulatedList() throws Exception { L40: Executor exec = Executors.newCachedThreadPool(); L41: CountDownLatch countDownLatch = new CountDownLatch(3); L42: list.add(new MockRunnable(countDownLatch), exec); L43: list.add(new MockRunnable(countDownLatch), exec); L44: ...

{@code loader} <b>must not</b> return L94: * {@code null}; it may either return a non-null value or throw an exception. L95: * L96: * <p>No observable state associated with this cache is modified until loading completes. L97: * L98: * @throws ExecutionException if a checked exception was thrown while loading the value L99: * @throws UncheckedExecutionException if an unchecked exception was thrown while loading the L100: * value L101: * @throws ExecutionError if an error was thrown while...

"AS IS" BASIS, L12: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, L13: * either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.exception; L17: L18:public class WebApiException extends FessSystemException { L19: L20: private static final long serialVersionUID = 1L; L21: L22: private final int statusCode; L23: L24: public int getStatusCode() { L25: return statusCode;...

j.Logger; L20:import org.codelibs.core.timer.TimeoutTask; L21:import org.codelibs.fess.Constants; L22:import org.codelibs.fess.es.config.exentity.JobLog; L23:import org.codelibs.fess.es.config.exentity.ScheduledJob; L24:import org.codelibs.fess.exception.ScheduledJobException; L25:import org.codelibs.fess.helper.JobHelper; L26:import org.codelibs.fess.helper.SystemHelper; L27:import org.codelibs.fess.job.JobExecutor; L28:import org.codelibs.fess.util.ComponentUtil; L29:import org.lastaflute.job.JobManager;...

L28: L29:/** L30: * Unit test for {@link AbstractLoadingCache}. L31: * L32: * @author Charles Fry L33: */ L34:public class AbstractLoadingCacheTest extends TestCase { L35: L36: public void testGetUnchecked_checked() { L37: final Exception cause = new Exception(); L38: final AtomicReference<Object> valueRef = new AtomicReference<>(); L39: LoadingCache<Object, Object> cache = L40: new AbstractLoadingCache<Object, Object>() { L41: @Override L42: public Object get(Object...

java.io.IOException; L19:import okhttp3.OkHttpClient; L20:import okhttp3.Request; L21:import okhttp3.Response; L22: L23:public final class AccessHeaders { L24: private final OkHttpClient client = new OkHttpClient(); L25: L26: public void run() throws Exception { L27: Request request = new Request.Builder() L28: .url("https://api.github.com/repos/square/okhttp/issues") L29: .header("User-Agent", "OkHttp Headers.java") L30: .addHeader("Accept", "application/json; q=0.5") L31: ...

okhttp3.OkHttpClient; L23:import okhttp3.Request; L24:import okhttp3.Response; L25:import okhttp3.ResponseBody; L26: L27:public final class AsynchronousGet { L28: private final OkHttpClient client = new OkHttpClient(); L29: L30: public void run() throws Exception { L31: Request request = new Request.Builder() L32: .url("http://publicobject.com/helloworld.txt") L33: .build(); L34: L35: client.newCall(request).enqueue(new Callback() { L36: @Override public void onFailure(Call call,...

{ L27: private final OkHttpClient client = new OkHttpClient(); L28: private final Moshi moshi = new Moshi.Builder().build(); L29: private final JsonAdapter<Gist> gistJsonAdapter = moshi.adapter(Gist.class); L30: L31: public void run() throws Exception { L32: Request request = new Request.Builder() L33: .url("https://api.github.com/gists/c2a7c39532239ff261be") L34: .build(); L35: try (Response response = client.newCall(request).execute()) { L36: if (!response.isSuccessful())...