public static InstanceUrlClosure ClusterConfigBasedUrlClosure = new InstanceUrlClosure() {

	private final DynamicStringProperty defaultUrlClosureConfig = DynamicPropertyFactory
			    .getInstance().getStringProperty("turbine.instanceUrlSuffix",
				    	"hystrix.stream");
	private final DynamicBooleanProperty instanceInsertPort = DynamicPropertyFactory
				.getInstance().getBooleanProperty("turbine.instanceInsertPort", true);

	@Override
	public String getUrlPath(Instance host) {
		if (host.getCluster() == null) {
			throw new RuntimeException(
					"Host must have cluster name in order to use ClusterConfigBasedUrlClosure");
		}

		// find url
		String key = "turbine.instanceUrlSuffix." + host.getCluster();
		DynamicStringProperty urlClosureConfig = DynamicPropertyFactory.getInstance()
					.getStringProperty(key, null);
		String url = urlClosureConfig.get();
		if (url == null) {
			url = this.defaultUrlClosureConfig.get();
		}
		if (url == null) {
			throw new RuntimeException("Config property: "
					+ urlClosureConfig.getName() + " or "
					+ this.defaultUrlClosureConfig.getName() + " must be set");
		}

		// find port and scheme
		String port;
		String scheme;
		if (host.getAttributes().containsKey("securePort")) {
			port = host.getAttributes().get("securePort");
			scheme = "https";
		} else {
			port = host.getAttributes().get("port");
			scheme = "http";
		}
		if (host.getAttributes().containsKey("fusedHostPort")) {
			return String.format("%s://%s/%s", scheme, host.getAttributes().get("fusedHostPort"), url);
		}

		// determine if to insert port
		String insertPortKey = "turbine.instanceInsertPort." + host.getCluster();
		DynamicStringProperty insertPortProp = DynamicPropertyFactory.getInstance()
					.getStringProperty(insertPortKey, null);
		boolean insertPort;
		if (insertPortProp.get() == null) {
			insertPort = this.instanceInsertPort.get();
		}
		else {
			insertPort = Boolean.parseBoolean(insertPortProp.get());
		}

		// format url with port
		if (insertPort) {
			if (url.startsWith("/")) {
				url = url.substring(1);
			}
			if (port == null) {
				throw new RuntimeException(
						"Configured to use port, but port or securePort is not in host attributes");
			}

			return String.format("%s://%s:%s/%s", scheme, host.getHostname(), port, url);
		}

		//format url without port
		return scheme + "://" + host.getHostname() + url;
	}
};