diff --git a/modules/distribution/carbon-home/conf/transports/netty-transports.yml b/modules/distribution/carbon-home/conf/transports/netty-transports.yml index a12f27614..c453a5d84 100644 --- a/modules/distribution/carbon-home/conf/transports/netty-transports.yml +++ b/modules/distribution/carbon-home/conf/transports/netty-transports.yml @@ -89,6 +89,7 @@ listenerConfigurations: id: "default" host: "0.0.0.0" port: 9090 + messageProcessorId: "MSF4J-CM-PROCESSOR" - id: "https" diff --git a/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListener.java b/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListener.java index 6cf826f43..795c643c0 100644 --- a/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListener.java +++ b/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListener.java @@ -35,7 +35,7 @@ public class HttpServerListener implements HttpHandler { private static final Logger logger = Logger.getLogger(HttpServerListener.class); private AtomicBoolean isEventArraved = new AtomicBoolean(false); - private StringBuilder strBld; + private StringBuilder strBld = new StringBuilder(); private Headers headers; HttpServerListener() { @@ -48,18 +48,17 @@ public void handle(HttpExchange t) throws IOException { headers = t.getRequestHeaders(); InputStream is = t.getRequestBody(); BufferedReader in = new BufferedReader(new InputStreamReader(is)); // initiating - strBld = new StringBuilder(); + String name = null; while ((line = in.readLine()) != null) { - strBld = strBld.append(line).append("\n"); - System.out.print(line + "\n"); + strBld = strBld.append(line).append(" , "); + name = line; } - logger.info("Event Arrived: " + strBld.toString()); + logger.info("Event Name Arrived: " + name); isEventArraved.set(true); } String getData() { - isEventArraved = new AtomicBoolean(false); return strBld.toString(); } @@ -67,7 +66,7 @@ Headers getHeaders() { return headers; } - boolean iaMessageArrive() { + boolean isMessageArrive() { return isEventArraved.get(); } diff --git a/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListenerHandler.java b/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListenerHandler.java index cb7ecd907..b7a2d89fd 100644 --- a/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListenerHandler.java +++ b/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerListenerHandler.java @@ -58,7 +58,7 @@ public void run() { } - public void shutdown() { + void shutdown() { if (server != null) { server.stop(1); } diff --git a/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerMain.java b/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerMain.java index c89d7ca94..1dadb3ecb 100644 --- a/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerMain.java +++ b/modules/samples/sample-clients/http-server/src/main/java/org/wso2/sp/http/server/HttpServerMain.java @@ -1,7 +1,7 @@ package org.wso2.sp.http.server; /** - * This is a sample HTTP server to receive events through HTTP/HTTPS protocol + * This is a sample HTTP server to receive events through HTTP/HTTPS protocol. */ public class HttpServerMain { private static final org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger(HttpServerMain.class); @@ -9,11 +9,12 @@ public class HttpServerMain { public static void main(String[] args) throws InterruptedException { while (true) { HttpServerListenerHandler lst = new HttpServerListenerHandler(8080); - while (!lst.getServerListner().iaMessageArrive()) { + while (!lst.getServerListner().isMessageArrive()) { Thread.sleep(100); } - logger.info("Received Event :" + lst.getServerListner().getData()); - logger.info("Received Event Headers :" + lst.getServerListner().getHeaders().toString()); + logger.info("Received Event Names:" + lst.getServerListner().getData()); + logger.info("Received Event Headers key set:" + lst.getServerListner().getHeaders().keySet().toString()); + logger.info("Received Event Headers value set:" + lst.getServerListner().getHeaders().values().toString()); lst.shutdown(); } } diff --git a/pom.xml b/pom.xml index 811136669..1e6dd5853 100644 --- a/pom.xml +++ b/pom.xml @@ -676,9 +676,9 @@ [5.0.0, 6.0.0) 5.2.0-m3 - 4.3.0-m2 + 4.4.26 [4.0.0, 5.0.0) - 4.3.0-m2 + 4.4.26 2.3.2 [0.0.0, 3.0.0)