CoordinationDI.java 文件源码

@Bean
public CoordinationServer coordinationServer() {
    org.apache.commons.configuration.Configuration configuration = beanFactory
            .getBean(org.apache.commons.configuration.Configuration.class);

    int lockPort = configuration.getInt(
            CoordinationProperties.PROP.COORDINATION_LOCK_PORT.toString(),
            (Integer) CoordinationProperties.PROP.COORDINATION_LOCK_PORT
                    .getDefaultValue());

    int releaseLockPort = configuration
            .getInt(CoordinationProperties.PROP.COORDINATION_UNLOCK_PORT
                    .toString(),
                    (Integer) CoordinationProperties.PROP.COORDINATION_UNLOCK_PORT
                            .getDefaultValue());

    return new CoordinationServerImpl(lockPort, releaseLockPort,
            beanFactory.getBean(CoordinationLockHandler.class), beanFactory.getBean(
                    CoordinationUnLockHandler.class), beanFactory.getBean(
                            MetricChannel.class));
}