com.liferay.portal.fabric.netty.worker
Class NettyFabricWorkerStub<T extends Serializable>
java.lang.Object
com.liferay.portal.fabric.netty.worker.NettyFabricWorkerStub<T>
- All Implemented Interfaces:
- FabricWorker<T>, ProcessChannel<T>
public class NettyFabricWorkerStub<T extends Serializable>
- extends Object
- implements FabricWorker<T>
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
NettyFabricWorkerStub
public NettyFabricWorkerStub(long id,
io.netty.channel.Channel channel,
Repository<io.netty.channel.Channel> repository,
Map<java.nio.file.Path,java.nio.file.Path> outputPathMap,
long rpcRelayTimeout)
getFabricStatus
public FabricStatus getFabricStatus()
- Specified by:
getFabricStatus in interface FabricWorker<T extends Serializable>
getProcessNoticeableFuture
public NoticeableFuture<T> getProcessNoticeableFuture()
- Specified by:
getProcessNoticeableFuture in interface ProcessChannel<T extends Serializable>
setCancel
public void setCancel()
setException
public void setException(Throwable t)
setResult
public void setResult(T result)
write
public <V extends Serializable> NoticeableFuture<V> write(ProcessCallable<V> processCallable)
- Specified by:
write in interface ProcessChannel<T extends Serializable>