INNER CODE UNIT · Java

customizers

spring-cloud/spring-cloud-zookeeper · spring-cloud-zookeeper-core/src/main/java/org/springframework/cloud/zookeeper/CuratorFactory.java:151

			customizers = () -> Stream.of(customizer);
		}
		catch (IllegalStateException e) {
			customizers = () -> null;
		}
		try {
			return CuratorFactory.curatorFramework(properties, context.get(RetryPolicy.class), customizers,
					supplier(context, EnsembleProvider.class), supplier(context, TracerDriver.class));
		}
		catch (Exception e) {
			if (!optional) {
				log.error("Unable to connect to zookeeper", e);
				throw new ZookeeperConnectException("Unable to connect to zookeeper", e);
			}
			if (log.isDebugEnabled()) {
				log.debug("Unable to connect to zookeeper", e);
			}
		}

View source record →