private final ConfigProvider configProvider;
private final Set<DcpChannel> channels;
private volatile long configRev = -1;
private final ClientEnvironment env;
private final AtomicReference<CouchbaseBucketConfig> currentConfig;
<BUG>private final boolean ownsConfigProvider;
public Conductor(final ClientEnvironment env, ConfigProvider cp) {</BUG>
this.env = env;
<BUG>this.currentConfig = new AtomicReference<CouchbaseBucketConfig>();
configProvider = cp == null ? new HttpStreamingConfigProvider(env) : cp;</BUG>
ownsConfigProvider = cp == null;

private final ConfigProvider configProvider;
private final Set<DcpChannel> channels;
private volatile long configRev = -1;
private final ClientEnvironment env;
private final AtomicReference<CouchbaseBucketConfig> currentConfig;
private final boolean ownsConfigProvider;
private final SessionState sessionState;
public Conductor(final ClientEnvironment env, ConfigProvider cp) {
this.env = env;
this.currentConfig = new AtomicReference<CouchbaseBucketConfig>();
sessionState = new SessionState();
configProvider = cp == null ? new HttpStreamingConfigProvider(env) : cp;
ownsConfigProvider = cp == null;
