com.liferay.portal.fabric.netty.repository

Class NettyRepository

java.lang.Object

com.liferay.portal.fabric.netty.repository.NettyRepository

All Implemented Interfaces:

Repository<io.netty.channel.Channel>

public class NettyRepository
extends java.lang.Object
implements Repository<io.netty.channel.Channel>

Author:

Shuyang Zhou

Field Summary

Fields

Modifier and Type	Field and Description
protected com.liferay.petra.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 Summary

Constructors

Constructor and Description
NettyRepository(java.nio.file.Path repositoryPath, long getFileTimeout)

Method Summary

Modifier and Type	Method and Description
void	dispose(boolean delete)
com.liferay.petra.concurrent.AsyncBroker<java.nio.file.Path,FileResponse>	getAsyncBroker()
com.liferay.petra.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.petra.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.petra.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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

asyncBroker

protected final com.liferay.petra.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker

getFileTimeout

protected final long getFileTimeout

pathMap

protected final java.util.Map<java.nio.file.Path,java.nio.file.Path> pathMap

repositoryPath

protected final java.nio.file.Path repositoryPath

Constructor Detail

NettyRepository

public NettyRepository(java.nio.file.Path repositoryPath,
                       long getFileTimeout)

Method Detail

dispose

public void dispose(boolean delete)

Specified by:

dispose in interface Repository<io.netty.channel.Channel>

getAsyncBroker

public com.liferay.petra.concurrent.AsyncBroker<java.nio.file.Path,FileResponse> getAsyncBroker()

Specified by:

getAsyncBroker in interface Repository<io.netty.channel.Channel>

getFile

public com.liferay.petra.concurrent.NoticeableFuture<java.nio.file.Path> getFile(io.netty.channel.Channel channel,
                                                                                 java.nio.file.Path remoteFilePath,
                                                                                 java.nio.file.Path localFilePath,
                                                                                 boolean deleteAfterFetch)

Specified by:

getFile in interface Repository<io.netty.channel.Channel>

getFiles

public com.liferay.petra.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)

Specified by:

getFiles in interface Repository<io.netty.channel.Channel>

getRepositoryPath

public java.nio.file.Path getRepositoryPath()

Specified by:

getRepositoryPath in interface Repository<io.netty.channel.Channel>

getLastModifiedTime

protected static long getLastModifiedTime(java.nio.file.Path path)

getFile

protected com.liferay.petra.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)