- final ConcurrentMap<Class, MessageCounters> newmap = new ConcurrentHashMap<>();
- final ConcurrentMap<Class, MessageCounters> check = inputStats.putIfAbsent(statGroup, newmap);
+ final ConcurrentMap<Class<?>, MessageCounters> newmap = new ConcurrentHashMap<>();
+ final ConcurrentMap<Class<?>, MessageCounters> check = inputStats.putIfAbsent(statGroup, newmap);