X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FModifyPeerCommandImpl.java;h=58d750d78a08d4a62ea46d3eb46d9d12e3b27429;hb=9771e7d3abc939fe9a03ff60c25ec9d8ec0bb4b9;hp=e709e5bcae89f3d197b1179bbffd379e95b604ac;hpb=0f78584d4108e8c93a7e5e2146da516cec36b383;p=jFCPlib.git

diff --git a/src/main/java/net/pterodactylus/fcp/quelaton/ModifyPeerCommandImpl.java b/src/main/java/net/pterodactylus/fcp/quelaton/ModifyPeerCommandImpl.java
index e709e5b..58d750d 100644
--- a/src/main/java/net/pterodactylus/fcp/quelaton/ModifyPeerCommandImpl.java
+++ b/src/main/java/net/pterodactylus/fcp/quelaton/ModifyPeerCommandImpl.java
@@ -28,6 +28,7 @@ public class ModifyPeerCommandImpl implements ModifyPeerCommand {
 	private final AtomicReference<Boolean> enabled = new AtomicReference<>();
 	private final AtomicReference<Boolean> allowLocalAddresses = new AtomicReference<>();
 	private final AtomicReference<Boolean> burstOnly = new AtomicReference<>();
+	private final AtomicReference<Boolean> listenOnly = new AtomicReference<>();
 
 	public ModifyPeerCommandImpl(ExecutorService threadPool, ConnectionSupplier connectionSupplier) {
 		this.threadPool = MoreExecutors.listeningDecorator(threadPool);
@@ -71,6 +72,12 @@ public class ModifyPeerCommandImpl implements ModifyPeerCommand {
 	}
 
 	@Override
+	public ModifyPeerCommand setListenOnly() {
+		listenOnly.set(true);
+		return this;
+	}
+
+	@Override
 	public Executable<Optional<Peer>> byName(String name) {
 		nodeIdentifier.set(name);
 		return this::execute;
@@ -97,6 +104,7 @@ public class ModifyPeerCommandImpl implements ModifyPeerCommand {
 		Optional.ofNullable(enabled.get()).ifPresent(enabled -> modifyPeer.setEnabled(enabled));
 		Optional.ofNullable(allowLocalAddresses.get()).ifPresent(allowed -> modifyPeer.setAllowLocalAddresses(allowed));
 		Optional.ofNullable(burstOnly.get()).ifPresent(burstOnly -> modifyPeer.setBurstOnly(burstOnly));
+		Optional.ofNullable(listenOnly.get()).ifPresent(listenOnly -> modifyPeer.setListenOnly(listenOnly));
 		try (ModifyPeerDialog modifyPeerDialog = new ModifyPeerDialog()) {
 			return modifyPeerDialog.send(modifyPeer).get();
 		}