alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-784 Changing var name

Browse Source
This commit is contained in:
Gunnar Morling 2018-09-18 09:55:43 +02:00
parent a459c2cc4d
commit 6f0d11cc64
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/ConnectionContext.java
View File

@ -223,7 +223,7 @@ public static class MongoPrimary {
private final Supplier<MongoClient> primaryConnectionSupplier; private final Supplier<MongoClient> primaryConnectionSupplier;
private final Filters filters; private final Filters filters;
private final BiConsumer<String, Throwable> errorHandler; private final BiConsumer<String, Throwable> errorHandler;
private final AtomicBoolean stop = new AtomicBoolean(); private final AtomicBoolean stopped = new AtomicBoolean();
protected MongoPrimary(ConnectionContext context, ReplicaSet replicaSet, Filters filters, BiConsumer<String, Throwable> errorHandler) { protected MongoPrimary(ConnectionContext context, ReplicaSet replicaSet, Filters filters, BiConsumer<String, Throwable> errorHandler) {
this.replicaSet = replicaSet; this.replicaSet = replicaSet;
@ -399,14 +399,14 @@ public List<CollectionId> collections() {
} }
private boolean isRunning() { private boolean isRunning() {
return stop.get(); return stopped.get();
} }
/** /**
* Terminates the execution loop of the current primary * Terminates the execution loop of the current primary
*/ */
public void stop() { public void stop() {
stop.set(true); stopped.set(true);
} }
} }