CLOUD-1576 prevent multiple servers from being created; use same server for all channels

Author: rcernich

common/src/main/java/org/openshift/ping/common/server/AbstractServerFactory.java

@@ -0,0 +1,22 @@
+package org.openshift.ping.common.server;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public abstract class AbstractServerFactory implements ServerFactory {
+
+    private static final Map<Integer, Server> SERVERS = new HashMap<Integer, Server>();
+
+    @Override
+    public synchronized final Server getServer(int port) {
+        Server server = SERVERS.get(port);
+        if (server == null) {
+            server = createServer(port);
+            SERVERS.put(port, server);
+        }
+        return server;
+    }
+
+    public abstract Server createServer(int port);
+
+}

common/src/main/java/org/openshift/ping/common/server/JBossServerFactory.java

@@ -19,7 +19,7 @@
 /**
  * @author <a href="mailto:[email protected]">Ales Justin</a>
  */
-public class JBossServerFactory implements ServerFactory {
+public class JBossServerFactory extends AbstractServerFactory {
 
     public boolean isAvailable() {
         try {
@@ -30,7 +30,7 @@ public boolean isAvailable() {
     }
 
     @Override
-    public Server getServer(int port) {
+    public Server createServer(int port) {
         return new JBossServer(port);
     }
 

common/src/main/java/org/openshift/ping/common/server/JDKServerFactory.java

@@ -19,7 +19,7 @@
 /**
  * @author <a href="mailto:[email protected]">Ales Justin</a>
  */
-public class JDKServerFactory implements ServerFactory {
+public class JDKServerFactory extends AbstractServerFactory {
 
     public boolean isAvailable() {
         try {
@@ -30,7 +30,7 @@ public boolean isAvailable() {
     }
 
     @Override
-    public Server getServer(int port) {
+    public Server createServer(int port) {
         return new JDKServer(port);
     }
 

common/src/main/java/org/openshift/ping/common/server/UndertowServerFactory.java

@@ -19,7 +19,7 @@
 /**
  * @author <a href="mailto:[email protected]">Ales Justin</a>
  */
-public class UndertowServerFactory implements ServerFactory {
+public class UndertowServerFactory extends AbstractServerFactory {
 
     public boolean isAvailable() {
         try {
@@ -30,7 +30,7 @@ public boolean isAvailable() {
     }
 
     @Override
-    public Server getServer(int port) {
+    public Server createServer(int port) {
         return new UndertowServer(port);
     }