Liferay 7.0-ce-m2

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

java.lang.Object
  extended by com.liferay.portal.fabric.netty.repository.NettyRepository
All Implemented Interfaces:
Repository

public class NettyRepository
extends Object
implements Repository


Field Summary
protected  AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker
           
protected  io.netty.channel.Channel channel
           
protected  long getFileTimeout
           
protected  Map<java.nio.file.Path,java.nio.file.Path> pathMap
           
protected  java.nio.file.Path repositoryPath
           
 
Constructor Summary
NettyRepository(java.nio.file.Path repositoryPath, io.netty.channel.Channel channel, io.netty.util.concurrent.EventExecutorGroup eventExecutorGroup, long getFileTimeout)
           
 
Method Summary
 void dispose(boolean delete)
           
 NoticeableFuture<java.nio.file.Path> getFile(java.nio.file.Path remoteFilePath, java.nio.file.Path localFilePath, boolean deleteAfterFetch)
           
protected  NoticeableFuture<java.nio.file.Path> getFile(java.nio.file.Path remoteFilePath, java.nio.file.Path localFilePath, boolean deleteAfterFetch, boolean populateCache)
           
 NoticeableFuture<Map<java.nio.file.Path,java.nio.file.Path>> getFiles(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 AsyncBroker<java.nio.file.Path,FileResponse> asyncBroker

channel

protected final io.netty.channel.Channel channel

getFileTimeout

protected final long getFileTimeout

pathMap

protected final 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,
                       io.netty.channel.Channel channel,
                       io.netty.util.concurrent.EventExecutorGroup eventExecutorGroup,
                       long getFileTimeout)
Method Detail

dispose

public void dispose(boolean delete)
Specified by:
dispose in interface Repository

getFile

public NoticeableFuture<java.nio.file.Path> getFile(java.nio.file.Path remoteFilePath,
                                                    java.nio.file.Path localFilePath,
                                                    boolean deleteAfterFetch)
Specified by:
getFile in interface Repository

getFiles

public NoticeableFuture<Map<java.nio.file.Path,java.nio.file.Path>> getFiles(Map<java.nio.file.Path,java.nio.file.Path> pathMap,
                                                                             boolean deleteAfterFetch)
Specified by:
getFiles in interface Repository

getRepositoryPath

public java.nio.file.Path getRepositoryPath()
Specified by:
getRepositoryPath in interface Repository

getLastModifiedTime

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

getFile

protected NoticeableFuture<java.nio.file.Path> getFile(java.nio.file.Path remoteFilePath,
                                                       java.nio.file.Path localFilePath,
                                                       boolean deleteAfterFetch,
                                                       boolean populateCache)

Liferay 7.0-ce-m2