parallec
parallec copied to clipboard
eBay
Fast Parallel Async HTTP/SSH/TCP/UDP/Ping Client Java Library. Aggregate 100,000 APIs & send anywhere in 20 lines of code. Ping/HTTP Calls 8000 servers in 12 seconds. (Akka) www.parallec.io
When `ParallelClient.releaseExternalResources ` is called while `ParallelTaskBuilder.execute` is waiting for a task to complete is sync mode then `ParallelTaskBiulder` hangs forever in this `while`: https://github.com/eBay/parallec/blob/1b4f1628f34fedfb06b24c33a5372d64d3df0952/src/main/java/io/parallec/core/ParallelTaskBuilder.java#L278 Even calling `interrupt` on executing...
Hi，I want to login in multiple hosts with different password and excute different command concurrently, so I tried the following groovy code ```groovy String vmIp = "host1 host2 host3 host4"...
Hi, We are trying to create multiple instances of Parallec and execute Bulk jobs in each one of them. We need to config different concurrency and timeout values in each...
Hi, Is it possible to perform bulk job of multiple POST requests? While each request has the same URL but different body. Thanks.
Hi Team, This is a feature request, the `parallec` library works beautifully for making parallel requests and is blazing fast. However, It'd be really nice to enable a way to...
Hi there, I have this code ``` ParallelTask pt = parallelClient.prepareHttpGet("/search/query?q=$QUERY") .setHttpHeaders(new ParallecHeader().addPair("x-user", env.getProperty("ifi.user")).addPair("x-password", env.getProperty("ifi.password"))).setProtocol(RequestProtocol.HTTPS) .setHttpPort(443) .async() .setReplaceVarMapToSingleTargetSingleVar("QUERY", queryList, "cdws21.ificlaims.com") .setResponseContext(returnMap) .execute((res, responseContext) -> { String resourcePath = res.getRequest().getResourcePath(); String...
I have two servers, A and B. For server A, i got 3 requests, i.e., a1, a2, a3. Similarly, i got 3 request on server B, i.e., b1, b2, b3....
Update Doc: set the connection timeout < request timeout < worker timeout. Then the async client timeout will kick in first before the actor timeout. ``` java ParallecGlobalConfig.ningFastClientConnectionTimeoutMillis = 4000;...