Prevent duplicate stats in HA mode

Author: LEDfan

src/main/java/eu/openanalytics/containerproxy/event/BridgeableEvent.java

@@ -30,10 +30,12 @@
 )
 public abstract class BridgeableEvent extends ApplicationEvent {
 
+    public static final String SOURCE_NOT_AVAILABLE = "SOURCE_NOT_AVAILABLE";
+
     public abstract BridgeableEvent withSource(String source);
 
     public BridgeableEvent() {
-        super("SOURCE_NOT_AVAILABLE");
+        super(SOURCE_NOT_AVAILABLE);
     }
 
 }

src/main/java/eu/openanalytics/containerproxy/stat/impl/AbstractDbCollector.java

@@ -26,26 +26,36 @@
 
 import java.io.IOException;
 
+import static eu.openanalytics.containerproxy.event.BridgeableEvent.SOURCE_NOT_AVAILABLE;
+
 public abstract class AbstractDbCollector implements IStatCollector {
 
     @EventListener
     public void onUserLogoutEvent(UserLogoutEvent event) throws IOException {
-        writeToDb(event.getTimestamp(), event.getUserId(), "Logout",null);
+        if (event.getSource().equals(SOURCE_NOT_AVAILABLE)) {
+            writeToDb(event.getTimestamp(), event.getUserId(), "Logout", null);
+        }
     }
 
     @EventListener
     public void onUserLoginEvent(UserLoginEvent event) throws IOException {
-        writeToDb(event.getTimestamp(), event.getUserId(), "Login", null);
+        if (event.getSource().equals(SOURCE_NOT_AVAILABLE)) {
+            writeToDb(event.getTimestamp(), event.getUserId(), "Login", null);
+        }
     }
 
     @EventListener
     public void onProxyStartEvent(ProxyStartEvent event) throws IOException {
-        writeToDb(event.getTimestamp(), event.getUserId(), "ProxyStart", event.getSpecId());
+        if (event.getSource().equals(SOURCE_NOT_AVAILABLE)) {
+            writeToDb(event.getTimestamp(), event.getUserId(), "ProxyStart", event.getSpecId());
+        }
     }
 
     @EventListener
     public void onProxyStopEvent(ProxyStopEvent event) throws IOException {
-        writeToDb(event.getTimestamp(), event.getUserId(), "ProxyStop", event.getSpecId());
+        if (event.getSource().equals(SOURCE_NOT_AVAILABLE)) {
+            writeToDb(event.getTimestamp(), event.getUserId(), "ProxyStop", event.getSpecId());
+        }
     }
 
     @EventListener