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)