class BeatProcessor implements Runnable {

	@Override
	public void run() {
		try {
			for (Map.Entry<String, BeatInfo> entry : dom2Beat.entrySet()) {
				BeatInfo beatInfo = entry.getValue();
				if (beatInfo.isScheduled()) {
					continue;
				}
				beatInfo.setScheduled(true);
				executorService.schedule(new BeatTask(beatInfo), 0, TimeUnit.MILLISECONDS);
			}
		} catch (Exception e) {
			NAMING_LOGGER.error("[CLIENT-BEAT] Exception while scheduling beat.", e);
		} finally {
			executorService.schedule(this, clientBeatInterval, TimeUnit.MILLISECONDS);
		}
	}
}

class BeatTask implements Runnable {

	BeatInfo beatInfo;

	public BeatTask(BeatInfo beatInfo) {
		this.beatInfo = beatInfo;
	}

	@Override
	public void run() {
		long result = serverProxy.sendBeat(beatInfo);
		beatInfo.setScheduled(false);
		if (result > 0) {
			clientBeatInterval = result;
		}
	}
}

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Scope {

	/**
	 * Alias for {@link #scopeName}.
	 * @see #scopeName
	 */
	@AliasFor("scopeName")
	String value() default "";

	/**
	 * Specifies the name of the scope to use for the annotated component/bean.
	 * <p>Defaults to an empty string ({@code ""}) which implies
	 * {@link ConfigurableBeanFactory#SCOPE_SINGLETON SCOPE_SINGLETON}.
	 * @since 4.2
	 * @see ConfigurableBeanFactory#SCOPE_PROTOTYPE
	 * @see ConfigurableBeanFactory#SCOPE_SINGLETON
	 * @see org.springframework.web.context.WebApplicationContext#SCOPE_REQUEST
	 * @see org.springframework.web.context.WebApplicationContext#SCOPE_SESSION
	 * @see #value
	 */
	@AliasFor("value")
	String scopeName() default "";

	/**
	 * Specifies whether a component should be configured as a scoped proxy
	 * and if so, whether the proxy should be interface-based or subclass-based.
	 * <p>Defaults to {@link ScopedProxyMode#DEFAULT}, which typically indicates
	 * that no scoped proxy should be created unless a different default
	 * has been configured at the component-scan instruction level.
	 * <p>Analogous to {@code <aop:scoped-proxy/>} support in Spring XML.
	 * @see ScopedProxyMode
	 */
	ScopedProxyMode proxyMode() default ScopedProxyMode.DEFAULT;

}

// String queryList(String serviceName, String clusters, int udpPort, boolean healthyOnly)
serverProxy.queryList(serviceName, clusters, 0, false);

@Service("consistencyDelegate")
public class DelegateConsistencyServiceImpl implements ConsistencyService {

    @Autowired
    private PersistentConsistencyService persistentConsistencyService;

    @Autowired
    private EphemeralConsistencyService ephemeralConsistencyService;
}