|
|
|
@ -15,8 +15,9 @@
|
|
|
|
|
* specific language governing permissions and limitations
|
|
|
|
|
* under the License.
|
|
|
|
|
*/
|
|
|
|
|
package io.entgra.device.mgt.core.server.bootup.heartbeat.beacon.service;
|
|
|
|
|
package io.entgra.device.mgt.core.device.mgt.core.push.notification.mgt;
|
|
|
|
|
|
|
|
|
|
import io.entgra.device.mgt.core.server.bootup.heartbeat.beacon.service.ClusterFormationChangedNotifier;
|
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
|
import org.apache.commons.logging.Log;
|
|
|
|
|
import org.apache.commons.logging.LogFactory;
|
|
|
|
@ -40,7 +41,7 @@ public class ClusterFormationChangedNotifierRepository {
|
|
|
|
|
public void addNotifier(String className) {
|
|
|
|
|
try {
|
|
|
|
|
if (!StringUtils.isEmpty(className)) {
|
|
|
|
|
Class<?> clz = Class.forName(className);
|
|
|
|
|
Class<?> clz = ClassLoader.getSystemClassLoader()forName(className);
|
|
|
|
|
ClusterFormationChangedNotifier notifier = (ClusterFormationChangedNotifier) clz.newInstance();
|
|
|
|
|
notifiers.put(notifier.getType(), notifier);
|
|
|
|
|
}
|
|
|
|
|