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

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
robertroeser committed Dec 23, 2018
1 parent 3e150c8 commit 3428316
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -69,9 +69,9 @@ public class DefaultProteusBrokerService implements ProteusBrokerService, Dispos
private final PresenceNotifier presenceNotifier;
private final MonoProcessor<Void> onClose;
private int missed = 0;

private final int selectRefresh;

private volatile Disposable disposable;

public DefaultProteusBrokerService(
Expand Down Expand Up @@ -405,7 +405,7 @@ private synchronized void createConnection() {
members.add(rSocket);
}
}

private RSocket selectRSocket() {
RSocket rSocket;
List<WeightedReconnectingRSocket> _m;
Expand Down

0 comments on commit 3428316

Please sign in to comment.