import net.pterodactylus.fcp.ProtocolError;
import net.pterodactylus.fcp.RemovePeer;
import net.pterodactylus.fcp.SSKKeypair;
-import net.pterodactylus.fcp.WatchGlobal;
import net.pterodactylus.util.thread.ObjectWrapper;
/**
@Override
@SuppressWarnings("synthetic-access")
public void run() throws IOException {
- fcpConnection.sendMessage(new WatchGlobal(global));
fcpConnection.sendMessage(new ListPersistentRequests());
}
*/
@Override
public void receivedPersistentGet(FcpConnection fcpConnection, PersistentGet persistentGet) {
- getRequests.add(persistentGet);
+ if (!persistentGet.isGlobal() || global) {
+ getRequests.add(persistentGet);
+ }
}
/**