diff --git a/monitor/src/main/java/bisq/monitor/metric/P2PNetworkLoad.java b/monitor/src/main/java/bisq/monitor/metric/P2PNetworkLoad.java index fca42ac66a..930d0d4413 100644 --- a/monitor/src/main/java/bisq/monitor/metric/P2PNetworkLoad.java +++ b/monitor/src/main/java/bisq/monitor/metric/P2PNetworkLoad.java @@ -35,15 +35,14 @@ import bisq.network.p2p.network.TorNetworkNode; import bisq.network.p2p.peers.PeerManager; import bisq.network.p2p.peers.keepalive.KeepAliveManager; import bisq.network.p2p.peers.peerexchange.PeerExchangeManager; -import bisq.network.p2p.peers.peerexchange.PeerList; import bisq.network.p2p.storage.messages.BroadcastMessage; import bisq.common.ClockWatcher; import bisq.common.config.Config; import bisq.common.file.CorruptedStorageFileHandler; +import bisq.common.persistence.PersistenceManager; import bisq.common.proto.network.NetworkEnvelope; import bisq.common.proto.network.NetworkProtoResolver; -import bisq.common.storage.Storage; import java.time.Clock; @@ -134,7 +133,7 @@ public class P2PNetworkLoad extends Metric implements MessageListener, SetupList networkProtoResolver, storageDir, corruptedStorageFileHandler); DefaultSeedNodeRepository seedNodeRepository = new DefaultSeedNodeRepository(config); PeerManager peerManager = new PeerManager(networkNode, seedNodeRepository, new ClockWatcher(), - maxConnections, new Storage(storageDir, persistenceProtoResolver, corruptedStorageFileHandler)); + maxConnections, new PersistenceManager<>(storageDir, persistenceProtoResolver, corruptedStorageFileHandler)); // init file storage peerManager.readPersisted();