Skip to content
This repository was archived by the owner on May 4, 2019. It is now read-only.

Commit 3428316

Browse files
committed
formatting
1 parent 3e150c8 commit 3428316

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

proteus-client/src/main/java/io/netifi/proteus/DefaultProteusBrokerService.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -69,9 +69,9 @@ public class DefaultProteusBrokerService implements ProteusBrokerService, Dispos
6969
private final PresenceNotifier presenceNotifier;
7070
private final MonoProcessor<Void> onClose;
7171
private int missed = 0;
72-
72+
7373
private final int selectRefresh;
74-
74+
7575
private volatile Disposable disposable;
7676

7777
public DefaultProteusBrokerService(
@@ -405,7 +405,7 @@ private synchronized void createConnection() {
405405
members.add(rSocket);
406406
}
407407
}
408-
408+
409409
private RSocket selectRSocket() {
410410
RSocket rSocket;
411411
List<WeightedReconnectingRSocket> _m;

0 commit comments

Comments
 (0)