Fix cluster communicator serialization ex
Change-Id: I1f9acf682fe741816f3c70665ae3520619cb8907
diff --git a/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java b/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java
index d101d60..5617017 100644
--- a/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java
+++ b/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java
@@ -15,17 +15,12 @@
*/
package org.opencord.igmpproxy;
-import org.slf4j.Logger;
-
import java.util.concurrent.atomic.AtomicLong;
-import static org.slf4j.LoggerFactory.getLogger;
-
/**
* Records metrics for IgmpProxy application.
*/
public class IgmpStatistics {
- private final Logger log = getLogger(getClass());
private static final long RESET_VALUE = 0L;
//Total number of join requests
@@ -223,7 +218,6 @@
failJoinReqInsuffPermissionAccessCounter.incrementAndGet();
break;
default:
- log.warn("Unhandled statistic type. {}", type);
break;
}
}
@@ -311,7 +305,6 @@
break;
default:
value = null;
- log.warn("Unhandled statistic type. {}", type);
break;
}
return value;
diff --git a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java
index 69ba6b6..ef932ef 100644
--- a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java
+++ b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java
@@ -93,6 +93,8 @@
private KryoNamespace statSerializer = KryoNamespace.newBuilder()
.register(KryoNamespaces.API)
.register(IgmpStatistics.class)
+ .register(ClusterMessage.class)
+ .register(MessageSubject.class)
.build();
//Statistics values are valid or invalid