fcpConnection.connect();
ClientHello clientHello = new ClientHello(name);
fcpConnection.sendMessage(clientHello);
+ WatchGlobal watchGlobal = new WatchGlobal(true);
+ fcpConnection.sendMessage(watchGlobal);
}
/**
@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);
+ }
}
/**