[Resteasy-users] Client Framework not honoring connection timeouts
Hello,
what is wrong with the code below? When using RestEasy Proxy Framework it
seems the client is not using the configuration for connection timeouts.
At line 54 there is a test url which returns response after 7 seconds, but
the call is not aborted as one might expect.
package si.najdi.httpclient;
import javax.ws.rs.ProcessingException;
import javax.ws.rs.core.Response;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.config.SocketConfig;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.jboss.resteasy.client.jaxrs.ResteasyClient;
import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
import org.jboss.resteasy.client.jaxrs.ResteasyWebTarget;
import org.jboss.resteasy.client.jaxrs.engines.ApacheHttpClient4Engine;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Main {
static Logger logger = LoggerFactory.getLogger(Main.class);
public static void main(String[] args) {
logger.info(Starting HttpClient test.);
SocketConfig socketConfig = SocketConfig.custom()
.setTcpNoDelay(true)
.setSoKeepAlive(true)
.setSoReuseAddress(true)
.build();
PoolingHttpClientConnectionManager connManager = new
PoolingHttpClientConnectionManager();
connManager.setMaxTotal(100);
connManager.setDefaultMaxPerRoute(100);
connManager.setDefaultSocketConfig(socketConfig);
RequestConfig defaultRequestConfig = RequestConfig.custom()
.setSocketTimeout(2000)
.setConnectTimeout(100)
.setConnectionRequestTimeout(3000)
.setStaleConnectionCheckEnabled(true)
.build();
CloseableHttpClient httpClient = HttpClients.custom()
.setDefaultRequestConfig(defaultRequestConfig)
.setConnectionManager(connManager)
.build();
ApacheHttpClient4Engine apacheHttpClient4Engine = new
ApacheHttpClient4Engine(httpClient);
ResteasyClient client = new
ResteasyClientBuilder().httpEngine(apacheHttpClient4Engine).build();
//String host = http://httpstat.us/400;;
String host = http://fake-response.appspot.com/?sleep=7;;
ResteasyWebTarget newsWebTarget = client.target(host);
NewsClient newsClient = newsWebTarget.proxy(NewsClient.class);
boolean ok = false;
Response response = null;
try {
logger.info(Calling...);
response = newsClient.clickIncrement(666);
logger.info(...returning);
if (response.getStatus() == Response.Status.OK.getStatusCode()) {
String line = (String) response.readEntity(String.class);
logger.info(Response line: + line);
} else {
String failMessage = response.getStatusInfo().getStatusCode() + +
response.getStatusInfo().getReasonPhrase();
logger.warn(Failed call. Reason: + failMessage);
}
} catch (ProcessingException e) {
logger.warn(Exception incrementing click counter. + e);
} finally {
if (response != null) {
response.close();
}
}
}
}
Here is the client interface if it matters:
import javax.ws.rs.DefaultValue;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.core.Response;
public interface NewsClient {
@GET
//@Path(clickcounter/news/{newsId})
Response clickIncrement(@PathParam(newsId) @DefaultValue(123)
String newsId);
}
The log output:
[12:05:46] INFO [si.najdi.httpclient.Main]: Starting HttpClient test.
[12:05:47] DEBUG [org.jboss.resteasy.plugins.providers.DocumentProvider]:
Unable to retrieve config: expandEntityReferences defaults to true
[12:05:47] DEBUG [org.jboss.resteasy.plugins.providers.DocumentProvider]:
Unable to retrieve config: expandEntityReferences defaults to true
[12:05:47] INFO [si.najdi.httpclient.Main]: Calling...
[12:05:54] INFO [si.najdi.httpclient.Main]: ...returning
[12:05:54] INFO [si.najdi.httpclient.Main]: Response line:
{response:This request has finsihed sleeping for 7 seconds}
Best regards,
borut
--
October Webinars: Code for Performance
Free Intel webinars can help you accelerate application performance.
Explore tips for MPI, OpenMP, advanced profiling, and more. Get the most from
the latest Intel processors and coprocessors. See abstracts and register
http://pubads.g.doubleclick.net/gampad/clk?id=60134071iu=/4140/ostg.clktrk___
Resteasy-users mailing list
Resteasy-users@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/resteasy-users
[Resteasy-users] POST method always returns Error status 401 Unauthorized
Hi,
I use the following code to call a web service using POST and always get
POST method always returns Error status 401 Unauthorized
Can someone help me to figure out what I do wrong in the bellow code?
Thanks in advance,
Nuwan
*FYI: webServiceUrl:
http://apitest.collabrx.com/oncovar/V1-0-7?client_id=XXXcommand=submit_sample
*
public Document post(String webServiceUrl, String data) throws
ExternalResourceConnectorException {
logger.debug(Posting data to URL: + webServiceUrl);
SAXReader saxReader = new SAXReader();
Document document = null;
StringBuffer responseMsg = new StringBuffer();
try {
ClientRequest request = new ClientRequest(webServiceUrl);
request.accept(application/xml);
request.body(MediaType.APPLICATION_XML, data); // data to be
identified.
ClientResponseString response = request.post(String.class);
//Object response = request.post().getEntity(new
GenericTypeObject(){});
if (response.getStatus() != 200) {
throw new RuntimeException(Failed : HTTP error code : +
response.getStatus());
}
BufferedReader br = new BufferedReader(new
InputStreamReader(new ByteArrayInputStream(response.getEntity()
.getBytes(;
String output;
while ((output = br.readLine()) != null) {
responseMsg.append(output);
}
logger.info(External web service response: +
responseMsg.toString());
document = saxReader.read(new
StringReader(responseMsg.toString()));
}
catch (ClientProtocolException e) {
throw new ExternalResourceConnectorException(e);
}
catch (IOException e) {
throw new ExternalResourceConnectorException(e);
}
catch (Exception e) {
throw new ExternalResourceConnectorException(e);
}
return document;
}
--
October Webinars: Code for Performance
Free Intel webinars can help you accelerate application performance.
Explore tips for MPI, OpenMP, advanced profiling, and more. Get the most from
the latest Intel processors and coprocessors. See abstracts and register
http://pubads.g.doubleclick.net/gampad/clk?id=60134071iu=/4140/ostg.clktrk___
Resteasy-users mailing list
Resteasy-users@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/resteasy-users
