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