ManagementAdapter.java 文件源码

/**
 * Handles LockService Creation
 * 
 * @param lockService
 */
public void handleLockServiceCreation(DLockService lockService) throws ManagementException {
  if (!isServiceInitialised("handleLockServiceCreation")) {
    return;
  }
  /** Internal Locks Should not be exposed to client for monitoring **/
  if (internalLocks.contains(lockService.getName())) {
    return;
  }
  LockServiceMBeanBridge bridge = new LockServiceMBeanBridge(lockService);
  LockServiceMXBean lockServiceMBean = new LockServiceMBean(bridge);

  ObjectName lockServiceMBeanName = MBeanJMXAdapter.getLockServiceMBeanName(
      cacheImpl.getDistributedSystem().getDistributedMember(), lockService.getName());

  ObjectName changedMBeanName =
      service.registerInternalMBean(lockServiceMBean, lockServiceMBeanName);

  service.federate(changedMBeanName, LockServiceMXBean.class, true);

  Notification notification = new Notification(JMXNotificationType.LOCK_SERVICE_CREATED,
      memberSource, SequenceNumber.next(), System.currentTimeMillis(),
      ManagementConstants.LOCK_SERVICE_CREATED_PREFIX + lockService.getName());
  memberLevelNotifEmitter.sendNotification(notification);

  memberMBeanBridge.addLockServiceStats(lockService);
}