Skip to content
Snippets Groups Projects
Commit 23c80092 authored by User expired's avatar User expired
Browse files

openolat#188: set a default timeout for connect, connectionRequest and socket...

openolat#188: set a default timeout for connect, connectionRequest and socket for adobeconnect backend connections
parent fbc32017
No related branches found
No related tags found
No related merge requests found
...@@ -30,6 +30,8 @@ import java.util.Locale; ...@@ -30,6 +30,8 @@ import java.util.Locale;
import javax.ws.rs.core.UriBuilder; import javax.ws.rs.core.UriBuilder;
import org.apache.http.HttpEntity; import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.config.RequestConfig.Builder;
import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.CloseableHttpClient;
...@@ -221,7 +223,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -221,7 +223,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
boolean ok = false; boolean ok = false;
HttpGet get = createAdminMethod(builder, errors); HttpGet get = createAdminMethod(builder, errors);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode == 200 || statusCode == 201) { if(statusCode == 200 || statusCode == 201) {
...@@ -296,7 +298,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -296,7 +298,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
boolean ok = false; boolean ok = false;
HttpGet get = createAdminMethod(builder, error); HttpGet get = createAdminMethod(builder, error);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode >= 200 && statusCode < 400) { if(statusCode >= 200 && statusCode < 400) {
...@@ -331,7 +333,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -331,7 +333,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
boolean ok = false; boolean ok = false;
HttpGet get = createAdminMethod(builder, error); HttpGet get = createAdminMethod(builder, error);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode >= 200 && statusCode < 400) { if(statusCode >= 200 && statusCode < 400) {
...@@ -365,7 +367,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -365,7 +367,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
boolean ok = false; boolean ok = false;
HttpGet get = createAdminMethod(builder, error); HttpGet get = createAdminMethod(builder, error);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode >= 200 && statusCode < 400) { if(statusCode >= 200 && statusCode < 400) {
...@@ -398,7 +400,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -398,7 +400,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
boolean ok = false; boolean ok = false;
HttpGet get = createAdminMethod(builder, errors); HttpGet get = createAdminMethod(builder, errors);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode >= 200 && statusCode < 400) { if(statusCode >= 200 && statusCode < 400) {
...@@ -462,7 +464,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -462,7 +464,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
List<AdobeConnectSco> shortCuts = null; List<AdobeConnectSco> shortCuts = null;
HttpGet get = createAdminMethod(builder, errors); HttpGet get = createAdminMethod(builder, errors);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode == 200) { if(statusCode == 200) {
...@@ -491,7 +493,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -491,7 +493,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
AdobeConnectPrincipal user = null; AdobeConnectPrincipal user = null;
HttpGet get = createAdminMethod(builder, errors); HttpGet get = createAdminMethod(builder, errors);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode == 200) { if(statusCode == 200) {
...@@ -563,7 +565,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -563,7 +565,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
BreezeSession session = null; BreezeSession session = null;
HttpGet getInfo = new HttpGet(uric); HttpGet getInfo = new HttpGet(uric);
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(getInfo)) { CloseableHttpResponse response = httpClient.execute(getInfo)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode == 200) { if(statusCode == 200) {
...@@ -592,7 +594,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -592,7 +594,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
.build(); .build();
HttpGet getLogin = new HttpGet(uri); HttpGet getLogin = new HttpGet(uri);
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(getLogin)) { CloseableHttpResponse response = httpClient.execute(getLogin)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode == 200) { if(statusCode == 200) {
...@@ -615,7 +617,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -615,7 +617,7 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
List<AdobeConnectSco> scos = null; List<AdobeConnectSco> scos = null;
HttpGet get = createAdminMethod(builder, errors); HttpGet get = createAdminMethod(builder, errors);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode == 200 || statusCode == 201) { if(statusCode == 200 || statusCode == 201) {
...@@ -629,12 +631,21 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI { ...@@ -629,12 +631,21 @@ public abstract class AbstractAdobeConnectProvider implements AdobeConnectSPI {
} }
return scos; return scos;
} }
private CloseableHttpClient buildHttpClient() {
RequestConfig requestConfig = RequestConfig.copy(RequestConfig.DEFAULT)
.setConnectTimeout(10000)
.setConnectionRequestTimeout(10000)
.setSocketTimeout(20000)
.build();
return HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).build();
}
protected List<AdobeConnectPrincipal> sendPrincipalRequest(UriBuilder builder, AdobeConnectErrors errors) { protected List<AdobeConnectPrincipal> sendPrincipalRequest(UriBuilder builder, AdobeConnectErrors errors) {
List<AdobeConnectPrincipal> users = null; List<AdobeConnectPrincipal> users = null;
HttpGet get = createAdminMethod(builder, errors); HttpGet get = createAdminMethod(builder, errors);
if(get != null) { if(get != null) {
try(CloseableHttpClient httpClient = HttpClientBuilder.create().build(); try(CloseableHttpClient httpClient = buildHttpClient();
CloseableHttpResponse response = httpClient.execute(get)) { CloseableHttpResponse response = httpClient.execute(get)) {
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if(statusCode == 200 || statusCode == 201) { if(statusCode == 200 || statusCode == 201) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment