checkstyle adherance
This commit is contained in:
parent
485c696d5e
commit
b7edb070fc
1 changed files with 2 additions and 2 deletions
|
@ -85,7 +85,6 @@ public class PrivateNotificationManager implements MessageListener {
|
||||||
this.networkNode = networkNode;
|
this.networkNode = networkNode;
|
||||||
this.mailboxMessageService = mailboxMessageService;
|
this.mailboxMessageService = mailboxMessageService;
|
||||||
this.keyRing = keyRing;
|
this.keyRing = keyRing;
|
||||||
this.useDevPrivilegeKeys = useDevPrivilegeKeys;
|
|
||||||
|
|
||||||
if (!ignoreDevMsg) {
|
if (!ignoreDevMsg) {
|
||||||
this.p2PService.addDecryptedDirectMessageListener(this::handleMessage);
|
this.p2PService.addDecryptedDirectMessageListener(this::handleMessage);
|
||||||
|
@ -190,11 +189,12 @@ public class PrivateNotificationManager implements MessageListener {
|
||||||
SettableFuture<Connection> future = networkNode.sendMessage(peersNodeAddress, ping);
|
SettableFuture<Connection> future = networkNode.sendMessage(peersNodeAddress, ping);
|
||||||
Futures.addCallback(future, new FutureCallback<>() {
|
Futures.addCallback(future, new FutureCallback<>() {
|
||||||
@Override
|
@Override
|
||||||
public void onSuccess(Connection connection) {
|
public void onSuccess(@SuppressWarnings("null") Connection connection) {
|
||||||
connection.addMessageListener(PrivateNotificationManager.this);
|
connection.addMessageListener(PrivateNotificationManager.this);
|
||||||
pingResponseHandler = resultHandler;
|
pingResponseHandler = resultHandler;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("null")
|
||||||
@Override
|
@Override
|
||||||
public void onFailure(@NotNull Throwable throwable) {
|
public void onFailure(@NotNull Throwable throwable) {
|
||||||
String errorMessage = "Sending ping to " + peersNodeAddress.getAddressForDisplay() +
|
String errorMessage = "Sending ping to " + peersNodeAddress.getAddressForDisplay() +
|
||||||
|
|
Loading…
Reference in a new issue