Skip to content

Commit

Permalink
Make spotless happy
Browse files Browse the repository at this point in the history
  • Loading branch information
slacmshankar committed Apr 16, 2024
1 parent b55092e commit e24e24f
Showing 1 changed file with 13 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -7,23 +7,21 @@
*******************************************************************************/
package org.epics.archiverappliance.retrieval.client;

import java.io.BufferedInputStream;
import java.io.InputStream;
import java.io.StringWriter;
import java.net.URI;
import java.net.URL;
import java.net.URLEncoder;
import java.net.http.HttpClient;
import java.net.http.HttpClient.Redirect;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.net.http.HttpResponse.BodyHandlers;
import java.nio.charset.StandardCharsets;
import java.sql.Timestamp;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.net.http.HttpClient;
import java.net.http.HttpClient.Redirect;
import java.net.http.HttpResponse.BodyHandlers;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

/**
* Client side class for retrieving data from the appliance archiver using the PB over HTTP protocol.
Expand All @@ -37,9 +35,8 @@ public class RawDataRetrieval extends DataRetrieval {

public RawDataRetrieval(String accessURL) {
this.accessURL = accessURL;
this.theClient = HttpClient.newBuilder()
.followRedirects(Redirect.NORMAL)
.build();
this.theClient =
HttpClient.newBuilder().followRedirects(Redirect.NORMAL).build();
}

private static String convertToUTC(Timestamp time) {
Expand Down Expand Up @@ -79,12 +76,14 @@ public final GenMsgIterator getDataForPVs(
});
}
String getURL = buf.toString();
logger.info("URL to fetch data is " + getURL);
logger.info("URL to fetch data is " + getURL);
try {
HttpRequest request = HttpRequest.newBuilder().uri(URI.create(getURL)).build();
HttpRequest request =
HttpRequest.newBuilder().uri(URI.create(getURL)).build();
HttpResponse<InputStream> response = this.theClient.send(request, BodyHandlers.ofInputStream());
if(response.statusCode() != 200) {
logger.warning("Invalid status code from server " + response.statusCode() + " when fetching data from " + getURL);
if (response.statusCode() != 200) {
logger.warning("Invalid status code from server " + response.statusCode() + " when fetching data from "
+ getURL);
return null;
}
return new InputStreamBackedGenMsg(response.body());
Expand Down

0 comments on commit e24e24f

Please sign in to comment.