Changeset 6396 for SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/scan/CenterRegistryLive.java

Timestamp:

07/17/15 09:57:49 (9 years ago)

Author:

emanuel.dima@uni-tuebingen.de

Message:

22. beta-53: accept any SSL connection to centres registry

File:

• SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/scan/CenterRegistryLive.java (modified) (5 diffs)

SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/scan/CenterRegistryLive.java

@@ -1 +1 @@
 package eu.clarin.sru.fcs.aggregator.scan;
 
-import eu.clarin.sru.fcs.aggregator.scan.EndpointFilter;
+import com.sun.jersey.api.client.Client;
 import eu.clarin.weblicht.bindings.cmd.StringBinding;
 import eu.clarin.weblicht.bindings.cmd.cp.CenterExtendedInformation;
@@ -24 +24 @@
 
         private static final Logger LOGGER = Logger.getLogger(CenterRegistryLive.class.getName());
+
+    private static final Integer CONNECT_TIMEOUT = 3000;
+    private static final Integer READ_TIMEOUT = 10000;
+
         private String centerRegistryUrl;
         private boolean hasInstitutionsLoaded = false;
         private List<Institution> centers = new ArrayList<Institution>();
         private final EndpointFilter filter;
+    private final Client client;
 
         public CenterRegistryLive(String centerRegistryUrl, EndpointFilter filter) {
@@ -33 +38 @@
                 this.centerRegistryUrl = centerRegistryUrl;
                 this.filter = filter;
+        this.client = ClientFactory.create(CONNECT_TIMEOUT, READ_TIMEOUT);
         }
 
@@ -42 +48 @@
         @Override
         public void loadCQLInstitutions() {
-
                 if (hasInstitutionsLoaded) {
                         return;
@@ -48 +53 @@
                 hasInstitutionsLoaded = true;
                 URI url = URI.create(centerRegistryUrl);
-                try (CenterRegistryConnector connector = new CenterRegistryConnector(url, 30000)) {
+                try (CenterRegistryConnector connector = new CenterRegistryConnector(client, url)) {
                         List<Center> regCenters = connector.retrieveCenters();
                         for (Center regCenter : regCenters) {