summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGokul Singaraju <goksing@gmail.com>2017-11-02 01:08:36 -0400
committerGokul Singaraju <goksing@gmail.com>2017-11-02 01:11:23 -0400
commit2a6d8d9a468469b3b424451d25b47e03745f304b (patch)
tree95721c8164041f215bb100e3a32daee6da2bdf70
parent0d3bbd92ce12ff1f2735a924e007641730dec2ff (diff)
Fix Javalib logging under server errors
Issue-Id: VNFSDK-121 Change-Id: I118cfae30a559f31588e28ff389d93895d6e9d7f Signed-Off-by: Gokul Singaraju <goksing@gmail.com>
-rw-r--r--veslibrary/ves_javalibrary/evel_javalib2/src/evel_javalibrary/att/com/AgentMain.java38
1 files changed, 23 insertions, 15 deletions
diff --git a/veslibrary/ves_javalibrary/evel_javalib2/src/evel_javalibrary/att/com/AgentMain.java b/veslibrary/ves_javalibrary/evel_javalib2/src/evel_javalibrary/att/com/AgentMain.java
index 22d5a0a..eff9a3e 100644
--- a/veslibrary/ves_javalibrary/evel_javalib2/src/evel_javalibrary/att/com/AgentMain.java
+++ b/veslibrary/ves_javalibrary/evel_javalib2/src/evel_javalibrary/att/com/AgentMain.java
@@ -89,7 +89,22 @@ public enum EVEL_ERR_CODES {
/* AgentDispatcher loops on messages in RingBuffer and POSTs them
* to external Collector
*/
- private static class AgentDispatcher implements Runnable {
+ private static class AgentDispatcher implements Runnable {
+
+ private String readStream(InputStream stream) throws Exception {
+ StringBuilder builder = new StringBuilder();
+ try (BufferedReader in = new BufferedReader(new InputStreamReader(stream))) {
+ String line;
+ while ((line = in.readLine()) != null) {
+ builder.append(line); // + "\r\n"(no need, json has no line breaks!)
+ }
+ in.close();
+ }
+ logger.error("Resp: " + builder.toString());
+ System.out.println("Resp: " + builder.toString());
+ return builder.toString();
+ }
+
public void run() {
String datatosend=null;
@@ -122,7 +137,7 @@ public enum EVEL_ERR_CODES {
// No caching, we want the real thing.
con.setUseCaches (false);
// Specify the content type.
- con.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
+ con.setRequestProperty("Content-Type", "application/json");
//con.setChunkedStreamingMode(0);
con.setInstanceFollowRedirects( false );
//Basic username password authentication
@@ -163,24 +178,17 @@ public enum EVEL_ERR_CODES {
logger.warn(url + " **SERVER ERROR**");
InputStream es = con.getErrorStream();
- if( es != null)
- {
- int ret = 0;
- byte[] buf = null;
- // read the response body
- while ((ret = es.read(buf)) > 0) {
- logger.info("Resp:"+buf);
- }
- // close the errorstream
- es.close();
- }
+ readStream(es);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
- }
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
}
else
@@ -319,4 +327,4 @@ public enum EVEL_ERR_CODES {
-} \ No newline at end of file
+}