Merge branch 'master' into fix/arcgis_exception_to_cygnus_persistence…

…_error

CHANGES_NEXT_RELEASE

@@ -1 +1,2 @@
 - [cygnus-ngsi][cygnus-common] Fix way to handle CygnusPersistenceException to allow batch retries in arcgis-sink if `.batch_ttl` configured
+- [cygnus-ngsi][cygnus-common] Remove new line chars from Arcgis logs

cygnus-common/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.telefonica.iot</groupId>
     <artifactId>cygnus-common</artifactId>
-    <version>3.15.0</version>
+    <version>3.15.0-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <name>cygnus-common</name>

cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/arcgis/restutils/ArcgisFeatureTable.java

@@ -89,11 +89,7 @@ protected ArcgisFeatureTable() {
     public ArcgisFeatureTable(String url, String user, String password, String tokenGenUrl,
                               boolean readOnly, int connectionTimeout, int readTimeout) {
         this();
-        LOGGER.debug("Arcgis constructor.. " + url);
-
-        LOGGER.debug("Arcgis url.. " + url);
-        LOGGER.debug("Arcgis tokenGenUrl.. " + tokenGenUrl);
-        LOGGER.debug("Arcgis readOnly.. " + readOnly);
+        LOGGER.debug("ArcgisFeatureTable constructor. Url: " + url + " tokenGenUrl: " + tokenGenUrl + " readOnly: " + readOnly);
 
         Credential credential = new UserCredential(user, password);
         try {
@@ -104,8 +100,8 @@ public ArcgisFeatureTable(String url, String user, String password, String token
             connected = true;
         } catch (ArcgisException e) {
             LOGGER.error("Arcgis error while connecting to Feature Table: (" + e.getMessage() + ")"
-                + "\n\t URL: " + url
-                + "\n\t tokenGenURL: " + tokenGenUrl);
+                + "\t URL: " + url
+                + "\t tokenGenURL: " + tokenGenUrl);
             connected = false;
             setError(e);
             this.errorDesc += "    " + url + "  -  " + tokenGenUrl;

cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/arcgis/restutils/CredentialRestApi.java

@@ -92,8 +92,8 @@ public CredentialRestApi(String tokenGenUrl, Credential credential, String refer
      * @throws ArcgisException
      */
     public Credential getCredential() throws ArcgisException {
-        LOGGER.debug("------------------ getCredential() " + "\n\t tokenGenUrl: " + tokenGenUrl
-                + "\n\t credential: " + credential + "\n\t credential.isExpired(): "
+        LOGGER.debug("------------------ getCredential() " + "\t tokenGenUrl: " + tokenGenUrl
+                + "\t credential: " + credential + "\t credential.isExpired(): "
                 + (credential != null ? credential.isExpired() : null));
         if (tokenGenUrl != null && (credential == null || credential.isExpired())) {
             LOGGER.debug("Creating/Refreshing token.");

cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/arcgis/restutils/RestApi.java

@@ -256,12 +256,12 @@ public boolean verify(String hostname, SSLSession session) {
 
         } catch (UnknownHostException e) {
             httpResponse.setResponseCode(HttpURLConnection.HTTP_NOT_FOUND);
-            httpResponse.setResponseMessage(e.getClass() + "\n" + e.getMessage());
+            httpResponse.setResponseMessage(e.getClass() + " error message: " + e.getMessage());
         } catch (IllegalArgumentException e) {
             httpResponse.setResponseMessage("Check url, it may have 'http:/' instead of 'http://' "
-                    + e.getClass() + "\n" + e.getMessage());
+                    + e.getClass() + " error message: " + e.getMessage());
         } catch (Exception e) {
-            httpResponse.setResponseMessage(e.getClass() + "\n" + e.getMessage());
+            httpResponse.setResponseMessage(e.getClass() + " error message: " + e.getMessage());
         } finally {
             LOGGER.debug("Disposing connection objects");
             if (rd != null) {
@@ -357,7 +357,7 @@ protected static void checkHttpResponse(String httpResponse) throws ArcgisExcept
             throw new ArcgisException("Unexpected response format" + httpResponse);
         } catch (IllegalStateException | ClassCastException e) {
             throw new ArcgisException("checkHttpResponse, Unexpected exception" + e.getMessage()
-                    + " \n\t" + httpResponse);
+                    + " httpResponse: " + httpResponse);
         } catch (NullPointerException e) {
             throw new ArcgisException(
                     "checkHttpResponse, Null Body recived from server." + httpResponse);
@@ -470,7 +470,7 @@ protected static void checkHttpSingleResponse(JsonObject node) throws ArcgisExce
             }
 
             throw new ArcgisException(errorCode,
-                    "Response Error " + errorCode + "  " + message + "\n" + details);
+                    "Response ErrorCode: " + errorCode + " message: " + message + " details: " + details);
         }
     }
 

cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/arcgis/restutils/RestFeatureTable.java

@@ -221,7 +221,7 @@ public ResultPage<Feature> getFeatureList(String whereClause, int pageOffset, St
         }
 
         HttpResponse response = httpGet(fullUrl, params, this.connectionTimeout, this.readTimeout);
-        LOGGER.debug("Response code: " + response.getResponseCode() + "\n\t" + response.getBody());
+        LOGGER.debug("Response code: " + response.getResponseCode() + "\t response body: " + response.getBody());
 
         checkResponse(response);
 
@@ -238,7 +238,7 @@ public ResultPage<Feature> getFeatureList(String whereClause, int pageOffset, St
      */
     protected void checkResponse(HttpResponse response) throws ArcgisException {
         if (!checkHttpResponse(response)) {
-            String errorMsg = "Error: " + response.getErrorCode() + "\n"
+            String errorMsg = "Error code: " + response.getErrorCode() + " error message: "
                     + response.getErrorMessage();
             LOGGER.error(errorMsg);
             throw new ArcgisException(errorMsg);
@@ -274,7 +274,7 @@ public void sendFeatureList(List<Feature> featureList, String action) throws Arc
         }
 
         HttpResponse response = httpPost(fullUrl, params, bodyParams, this.connectionTimeout, this.readTimeout);
-        LOGGER.debug("Response code: " + response.getResponseCode() + "\n\t" + response.getBody());
+        LOGGER.debug("Response code: " + response.getResponseCode() + "\t response body: " + response.getBody());
 
         checkResponse(response);
     }
@@ -359,7 +359,7 @@ public void deleteEntities(List<String> objectIdList) throws ArcgisException {
         }
 
         HttpResponse response = httpPost(fullUrl, params, bodyParams, this.connectionTimeout, this.readTimeout);
-        LOGGER.debug("Response code: " + response.getResponseCode() + "\n\t" + response.getBody());
+        LOGGER.debug("Response code: " + response.getResponseCode() + "\t response body: " + response.getBody());
 
         checkResponse(response);
 
@@ -406,7 +406,7 @@ public void getTableAttributesInfo() throws ArcgisException {
 
             LOGGER.debug("HttpGet " + fullUrl.toString() + " number of params: " + params.size());
             HttpResponse response = httpGet(fullUrl, params, this.connectionTimeout, this.readTimeout);
-            LOGGER.debug("Response code: " + response.getResponseCode() + "\n\t" + response.getBody());
+            LOGGER.debug("Response code: " + response.getResponseCode() + "\t response body: " + response.getBody());
 
             checkResponse(response);
 
@@ -421,8 +421,8 @@ public void getTableAttributesInfo() throws ArcgisException {
 
             } else {
                 String errorMsg = "getTableAttributesInfo: Unexpected server response, Error: "
-                        + response.getErrorCode() + "\n" + response.getErrorMessage();
-                errorMsg += " \n\t token: " + token;
+                        + response.getErrorCode() + " error message: " + response.getErrorMessage();
+                errorMsg += " \t token: " + token;
                 LOGGER.error(errorMsg);
                 throw new ArcgisException(errorMsg);
             }

cygnus-ngsi-ld/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.telefonica.iot</groupId>
     <artifactId>cygnus-ngsi-ld</artifactId>
-    <version>3.15.0</version>
+    <version>3.15.0-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <name>cygnus-ngsi-ld</name>
@@ -60,7 +60,7 @@
         <dependency>
             <groupId>com.telefonica.iot</groupId>
             <artifactId>cygnus-common</artifactId>
-            <version>3.15.0</version>
+            <version>3.15.0-SNAPSHOT</version>
         </dependency>
     </dependencies>
 

cygnus-ngsi/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.telefonica.iot</groupId>
     <artifactId>cygnus-ngsi</artifactId>
-    <version>3.15.0</version>
+    <version>3.15.0-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <name>cygnus-ngsi</name>
@@ -63,7 +63,7 @@
         <dependency>
             <groupId>com.telefonica.iot</groupId>
             <artifactId>cygnus-common</artifactId>
-            <version>3.15.0</version>
+            <version>3.15.0-SNAPSHOT</version>
         </dependency>
         <!-- https://mvnrepository.com/artifact/org.jodd/jodd-util -->
         <dependency>

cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIArcgisFeatureTableSink.java

@@ -543,7 +543,7 @@ public void aggregate(NGSIEvent event) throws CygnusRuntimeError {
                 throw new CygnusRuntimeError(e.getMessage());
             } catch (Exception e) {
                 LOGGER.error("[NGSIArcgisAggregator] aggregate - Unexpected Error" + e.getMessage()
-                        + "\n contextElement: " + contextElement.toString());
+                        + " contextElement: " + contextElement.toString());
                 throw new CygnusRuntimeError(e.getMessage());
             }
 

cygnus-twitter/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.telefonica.iot</groupId>
     <artifactId>cygnus-twitter</artifactId>
-    <version>3.15.0</version>
+    <version>3.15.0-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <name>cygnus-twitter</name>
@@ -57,7 +57,7 @@
         <dependency>
             <groupId>com.telefonica.iot</groupId>
             <artifactId>cygnus-common</artifactId>
-            <version>3.15.0</version>
+            <version>3.15.0-SNAPSHOT</version>
         </dependency>
         <!-- Required by twitter agent -->
         <dependency>

docker/cygnus-common/Dockerfile

@@ -27,7 +27,7 @@ MAINTAINER Francisco Romero Bueno <[email protected]>
 # Environment variables
 ENV CYGNUS_USER "cygnus"
 ENV CYGNUS_HOME "/opt/fiware-cygnus"
-ENV CYGNUS_VERSION "3.15.0"
+ENV CYGNUS_VERSION "3.15.0-SNAPSHOT"
 ENV CYGNUS_CONF_PATH "/opt/apache-flume/conf"
 ENV CYGNUS_CONF_FILE "/opt/apache-flume/conf/agent.conf"
 ENV CYGNUS_AGENT_NAME "cygnus-common"
@@ -40,7 +40,7 @@ ENV CYGNUS_API_PORT "8081"
 # PR https://github.com/telefonicaid/fiware-cygnus/pull/1801 should be also done in this Dockerfile
 # NOTE: Configure correctly GIT_URL_CYGNUS and GIT_REV_CYGNUS for each git branch/fork used
 ENV GIT_URL_CYGNUS "https://github.com/telefonicaid/fiware-cygnus.git"
-ENV GIT_REV_CYGNUS "release/3.15.0"
+ENV GIT_REV_CYGNUS "master"
 
 ENV MVN_VER "3.5.4"
 ENV MVN_TGZ "apache-maven-${MVN_VER}-bin.tar.gz"

docker/cygnus-ngsi-ld/Dockerfile

@@ -27,7 +27,7 @@ ARG GITHUB_REPOSITORY=fiware-cygnus
 # Environment variables
 ENV CYGNUS_USER "cygnus"
 ENV CYGNUS_HOME "/opt/fiware-cygnus"
-ENV CYGNUS_VERSION "3.15.0"
+ENV CYGNUS_VERSION "3.15.0-SNAPSHOT"
 ENV CYGNUS_CONF_PATH "/opt/apache-flume/conf"
 ENV CYGNUS_CONF_FILE "/opt/apache-flume/conf/agent.conf"
 ENV CYGNUS_AGENT_NAME "cygnus-ngsi-ld"

docker/cygnus-ngsi/Dockerfile

@@ -23,7 +23,7 @@ ARG GITHUB_REPOSITORY=fiware-cygnus
 # Environment variables
 ENV CYGNUS_USER "cygnus"
 ENV CYGNUS_HOME "/opt/fiware-cygnus"
-ENV CYGNUS_VERSION "3.15.0"
+ENV CYGNUS_VERSION "3.15.0-SNAPSHOT"
 ENV CYGNUS_CONF_PATH "/opt/apache-flume/conf"
 ENV CYGNUS_CONF_FILE "/opt/apache-flume/conf/agent.conf"
 ENV CYGNUS_AGENT_NAME "cygnus-ngsi"

docker/cygnus-twitter/Dockerfile

@@ -27,7 +27,7 @@ MAINTAINER Javi Palanca <[email protected]>
 # Environment variables
 ENV CYGNUS_USER "cygnus"
 ENV CYGNUS_HOME "/opt/fiware-cygnus"
-ENV CYGNUS_VERSION "3.15.0"
+ENV CYGNUS_VERSION "3.15.0-SNAPSHOT"
 ENV CYGNUS_CONF_PATH "/opt/apache-flume/conf"
 ENV CYGNUS_CONF_FILE "/opt/apache-flume/conf/agent.conf"
 ENV CYGNUS_AGENT_NAME "cygnus-twitter"
@@ -39,7 +39,7 @@ ENV CYGNUS_JAVA_OPTS "-Xms2048m -Xmx4096m"
 # PR https://github.com/telefonicaid/fiware-cygnus/pull/1801 should be also done in this Dockerfile
 # NOTE: Configure correctly GIT_URL_CYGNUS and GIT_REV_CYGNUS for each git branch/fork used
 ENV GIT_URL_CYGNUS "https://github.com/telefonicaid/fiware-cygnus.git"
-ENV GIT_REV_CYGNUS "release/3.15.0"
+ENV GIT_REV_CYGNUS "master"
 
 ENV MVN_VER "3.5.4"
 ENV MVN_TGZ "apache-maven-${MVN_VER}-bin.tar.gz"