本文整理了Java中com.atlassian.sal.api.net.Request.setSoTimeout
方法的一些代码示例,展示了Request.setSoTimeout
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Request.setSoTimeout
方法的具体详情如下:
包路径:com.atlassian.sal.api.net.Request
类名称:Request
方法名:setSoTimeout
暂无
代码示例来源:origin: com.atlassian.plugins.rest/atlassian-rest-module
@Override
public JerseyRequest setSoTimeout(final int i) {
delegateRequest.setSoTimeout(i);
return this;
}
代码示例来源:origin: com.atlassian.applinks/applinks-plugin-core
public ApplicationLinkRequest setSoTimeout(int soTimeout)
{
return setDelegate(request.setSoTimeout(soTimeout));
}
代码示例来源:origin: com.atlassian.applinks/applinks-common
public ApplicationLinkRequest setSoTimeout(int soTimeout) {
return setDelegate(request.setSoTimeout(soTimeout));
}
代码示例来源:origin: com.marvelution.jira.plugins/jira-jenkins-plugin
@Override
public ApplicationStatus getStatus(URI url) {
try {
LOGGER.debug("Querying " + url + " for its online status.");
final Request<Request<?, Response>, Response> request = requestFactory.createRequest(Request.MethodType.GET, url.toString());
request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
return request.executeAndReturn(new ReturningResponseHandler<Response, ApplicationStatus>() {
@Override
public ApplicationStatus handle(final Response response) throws ResponseException {
return response.isSuccessful() || (response.getStatusCode() == HttpStatus.SC_FORBIDDEN) || (response.getStatusCode()
== HttpStatus.SC_UNAUTHORIZED) ? ApplicationStatus.AVAILABLE : ApplicationStatus.UNAVAILABLE;
}
});
} catch (ResponseException re) {
return ApplicationStatus.UNAVAILABLE;
}
}
代码示例来源:origin: com.marvelution.atlassian.suite.plugins/atlassian-sonarqube-common
@Override
public ApplicationStatus getStatus(URI url) {
try {
LOGGER.debug("Querying " + url + " for its online status.");
final Request<Request<?, Response>, Response> request =
requestFactory.createRequest(Request.MethodType.GET, url.toString());
request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
return request.executeAndReturn(new ReturningResponseHandler<Response, ApplicationStatus>() {
@Override
public ApplicationStatus handle(final Response response) throws ResponseException {
return response.isSuccessful() || (response.getStatusCode() == HttpStatus.SC_FORBIDDEN) ?
ApplicationStatus.AVAILABLE : ApplicationStatus.UNAVAILABLE;
}
});
} catch (ResponseException re) {
return ApplicationStatus.UNAVAILABLE;
}
}
代码示例来源:origin: com.atlassian.applinks/applinks-plugin-core
/**
* Does a GET on the baseurl and expects a 200 status code.
*
* @param url baseUrl of the peer.
* @return
*/
public ApplicationStatus getStatus(final URI url)
{
try
{
LOG.debug("Querying " + url + " for its online status.");
final Request<Request<?, Response>,Response> request = requestFactory
.createRequest(Request.MethodType.GET, url.toString());
request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
return request.executeAndReturn(new ReturningResponseHandler<Response,ApplicationStatus>()
{
public ApplicationStatus handle(final Response response) throws ResponseException
{
return response.isSuccessful() ?
ApplicationStatus.AVAILABLE :
ApplicationStatus.UNAVAILABLE;
}
});
}
catch (ResponseException re)
{
return ApplicationStatus.UNAVAILABLE;
}
}
}
代码示例来源:origin: com.atlassian.applinks/applinks-common
/**
* Does a GET on the baseurl and expects a 200 status code.
*
* @param url baseUrl of the peer.
* @return ApplicationStatus for the url
*/
public ApplicationStatus getStatus(final URI url) {
try {
LOG.debug("Querying " + url + " for its online status.");
final Request<Request<?, Response>, Response> request = requestFactory
.createRequest(Request.MethodType.GET, url.toString());
request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
return request.executeAndReturn(response -> response.isSuccessful() ?
ApplicationStatus.AVAILABLE :
ApplicationStatus.UNAVAILABLE);
} catch (ResponseException re) {
return ApplicationStatus.UNAVAILABLE;
}
}
}
代码示例来源:origin: com.atlassian.streams/streams-fisheye-plugin
public Iterable<ExternalActivityItem> getItems(ApplicationLink appLink, ExternalActivityItemSearchParams params) throws Exception
{
final String uri = remoteStreamsFeedUriBuilder.buildUri(appLink, params).toASCIIString();
try
{
final Request<?, ?> request = appLink.createAuthenticatedRequestFactory().createRequest(Request.MethodType.GET, uri);
request.setConnectionTimeout(CONNECTION_TIMEOUT);
request.setSoTimeout(SO_TIMEOUT);
return itemFactory.getItems(request.execute());
}
catch (Exception e)
{
log.warn("Cannot fetch remote feed from: " + uri);
throw e;
}
}
}
代码示例来源:origin: com.atlassian.applinks/applinks-common
.setSoTimeout(CONNECTION_TIMEOUT)
.setFollowRedirects(false)
.execute(new ResponseHandler<Response>() {
代码示例来源:origin: com.atlassian.applinks/applinks-plugin-core
.createRequest(Request.MethodType.GET, appLinksManifestUrl(url))
.setConnectionTimeout(CONNECTION_TIMEOUT)
.setSoTimeout(CONNECTION_TIMEOUT)
.setFollowRedirects(false)
.execute(new ResponseHandler()
代码示例来源:origin: com.atlassian.applinks/applinks-plugin
request.setSoTimeout(CREATE_APPLICATION_LINK_SOCKET_TIMEOUT);
内容来源于网络,如有侵权,请联系作者删除!