CoordinationDI.java 文件源码

@Bean
@Lazy
public CoordinationLockHandler coordinationLockHandler() {

    org.apache.commons.configuration.Configuration configuration = beanFactory
            .getBean(org.apache.commons.configuration.Configuration.class);

    int port = configuration.getInt(
            CoordinationProperties.PROP.LOCK_HOLDER_PING_PORT.toString(),
            (Integer) CoordinationProperties.PROP.LOCK_HOLDER_PING_PORT
                    .getDefaultValue());

    long lockTimeout = configuration.getLong(
            CoordinationProperties.PROP.COORDINATION_LOCK_TIMEOUT
                    .toString(),
            (Long) CoordinationProperties.PROP.COORDINATION_LOCK_TIMEOUT
                    .getDefaultValue());

    return new CoordinationLockHandler(
            beanFactory.getBean(CoordinationStatus.class),
            beanFactory.getBean(LockMemory.class),
            beanFactory.getBean(HazelcastFileTrackerStorage.class), port,
            lockTimeout,
            beanFactory.getBean(FileTrackerHistoryMemory.class));

}