@Override
				public void handle(RefreshCacheMessage message) {
					m_logger.info("Refresh cached file store");
					Set<String> requiredFilesDigest = message.getDisFilesDigest();
					File cacheDir = m_incomingDirectory.getFile();

					try {
						List<File> cachedFiles = getAllFilesInDirectory(cacheDir);
						cachedFiles
							.stream()
							.filter(file ->  !requiredFilesDigest.contains(getFileDigest(cacheDir, file)))
							.forEach(FileUtils::deleteQuietly);
					} catch (IOException e) {
						m_logger.info("Failed refresh cached file store", e);
					}
				}
Registers message handlers with a dispatcher.

@param messageDispatcher The dispatcher.
ngrinder-core/src/main/java/net/grinder/engine/agent/FileStore.java