diff --git a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/WorkerRestClient.java b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/WorkerRestClient.java index 58f6a49bc1..5efefd6524 100644 --- a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/WorkerRestClient.java +++ b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/WorkerRestClient.java @@ -48,7 +48,7 @@ */ public class WorkerRestClient { - private static final Logger logger = LoggerFactory.getLogger(WorkerRestClient.class); + private static final Logger LOG = LoggerFactory.getLogger(WorkerRestClient.class); public static void invokeStreamAdapter(String endpointUrl, String elementId) throws AdapterException { @@ -72,7 +72,7 @@ public static void stopStreamAdapter(String baseUrl, public static List getAllRunningAdapterInstanceDescriptions(String url) throws AdapterException { try { - logger.info("Requesting all running adapter description instances: " + url); + LOG.info("Requesting all running adapter description instances: " + url); var responseString = ExtensionServiceExecutions .extServiceGetRequest(url) .execute().returnContent().asString(); @@ -81,14 +81,14 @@ public static List getAllRunningAdapterInstanceDescriptions( return result; } catch (IOException e) { - logger.error("List of running adapters could not be fetched", e); + LOG.error("List of running adapters could not be fetched", e); throw new AdapterException("List of running adapters could not be fetched from: " + url); } } public static void startAdapter(String url, AdapterDescription ad) throws AdapterException { - logger.info("Trying to start adapter on endpoint {} ", url); + LOG.info("Trying to start adapter on endpoint {} ", url); triggerAdapterStateChange(ad, url, "started"); } @@ -96,7 +96,7 @@ public static void startAdapter(String url, public static void stopAdapter(AdapterDescription ad, String url) throws AdapterException { - logger.info("Trying to stop adapter on endpoint {} ", url); + LOG.info("Trying to stop adapter on endpoint {} ", url); triggerAdapterStateChange(ad, url, "stopped"); } @@ -114,10 +114,10 @@ private static void triggerAdapterStateChange(AdapterDescription ad, throw new AdapterException(exception.getMessage(), exception.getCause()); } - logger.info("Adapter {} on endpoint: " + url + " with Response: ", ad.getName() + responseString); + LOG.info("Adapter {} on endpoint: " + url + " with Response: ", ad.getName() + responseString); } catch (IOException e) { - logger.error("Adapter was not {} successfully", action, e); + LOG.error("Adapter was not {} successfully", action, e); throw new AdapterException("Adapter was not " + action + " successfully with url " + url, e); } } @@ -161,7 +161,7 @@ public static RuntimeOptionsResponse getConfiguration(String workerEndpoint, public static String getAssets(String workerPath) throws AdapterException { String url = workerPath + "/assets"; - logger.info("Trying to Assets from endpoint: " + url); + LOG.info("Trying to Assets from endpoint: " + url); try { return Request.Get(url) @@ -169,7 +169,7 @@ public static String getAssets(String workerPath) throws AdapterException { .socketTimeout(100000) .execute().returnContent().asString(); } catch (IOException e) { - logger.error(e.getMessage()); + LOG.error(e.getMessage()); throw new AdapterException("Could not get assets endpoint: " + url); } @@ -185,7 +185,7 @@ public static byte[] getIconAsset(String baseUrl) throws AdapterException { .execute().returnContent().asBytes(); return responseString; } catch (IOException e) { - logger.error(e.getMessage()); + LOG.error(e.getMessage()); throw new AdapterException("Could not get icon endpoint: " + url); } } @@ -199,7 +199,7 @@ public static String getDocumentationAsset(String baseUrl) throws AdapterExcepti .socketTimeout(100000) .execute().returnContent().asString(); } catch (IOException e) { - logger.error(e.getMessage()); + LOG.error(e.getMessage()); throw new AdapterException("Could not get documentation endpoint: " + url); } }