public class NettyRepository extends Object implements Repository<io.netty.channel.Channel>
Modifier and Type | Field and Description |
---|---|
protected com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> |
asyncBroker |
protected long |
getFileTimeout |
protected Map<Path,Path> |
pathMap |
protected Path |
repositoryPath |
Constructor and Description |
---|
NettyRepository(Path repositoryPath,
long getFileTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
dispose(boolean delete) |
com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> |
getAsyncBroker() |
com.liferay.petra.concurrent.NoticeableFuture<Path> |
getFile(io.netty.channel.Channel channel,
Path remoteFilePath,
Path localFilePath,
boolean deleteAfterFetch) |
protected com.liferay.petra.concurrent.NoticeableFuture<Path> |
getFile(io.netty.channel.Channel channel,
Path remoteFilePath,
Path localFilePath,
boolean deleteAfterFetch,
boolean populateCache) |
com.liferay.petra.concurrent.NoticeableFuture<Map<Path,Path>> |
getFiles(io.netty.channel.Channel channel,
Map<Path,Path> pathMap,
boolean deleteAfterFetch) |
protected static long |
getLastModifiedTime(Path path) |
Path |
getRepositoryPath() |
protected final com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> asyncBroker
protected final long getFileTimeout
protected final Map<Path,Path> pathMap
protected final Path repositoryPath
public void dispose(boolean delete)
dispose
in interface Repository<io.netty.channel.Channel>
public com.liferay.petra.concurrent.AsyncBroker<Path,FileResponse> getAsyncBroker()
getAsyncBroker
in interface Repository<io.netty.channel.Channel>
public com.liferay.petra.concurrent.NoticeableFuture<Path> getFile(io.netty.channel.Channel channel, Path remoteFilePath, Path localFilePath, boolean deleteAfterFetch)
getFile
in interface Repository<io.netty.channel.Channel>
public com.liferay.petra.concurrent.NoticeableFuture<Map<Path,Path>> getFiles(io.netty.channel.Channel channel, Map<Path,Path> pathMap, boolean deleteAfterFetch)
getFiles
in interface Repository<io.netty.channel.Channel>
public Path getRepositoryPath()
getRepositoryPath
in interface Repository<io.netty.channel.Channel>
protected static long getLastModifiedTime(Path path)
protected com.liferay.petra.concurrent.NoticeableFuture<Path> getFile(io.netty.channel.Channel channel, Path remoteFilePath, Path localFilePath, boolean deleteAfterFetch, boolean populateCache)