public class NettyFabricWorkerStub<T extends java.io.Serializable> extends java.lang.Object implements FabricWorker<T>
| Constructor and Description |
|---|
NettyFabricWorkerStub(long id,
io.netty.channel.Channel channel,
Repository<io.netty.channel.Channel> repository,
java.util.Map<java.nio.file.Path,java.nio.file.Path> outputPathMap,
long rpcRelayTimeout) |
| Modifier and Type | Method and Description |
|---|---|
FabricStatus |
getFabricStatus() |
com.liferay.portal.kernel.concurrent.NoticeableFuture<T> |
getProcessNoticeableFuture() |
void |
setCancel() |
void |
setException(java.lang.Throwable t) |
void |
setResult(T result) |
<V extends java.io.Serializable> |
write(com.liferay.portal.kernel.process.ProcessCallable<V> processCallable) |
public NettyFabricWorkerStub(long id,
io.netty.channel.Channel channel,
Repository<io.netty.channel.Channel> repository,
java.util.Map<java.nio.file.Path,java.nio.file.Path> outputPathMap,
long rpcRelayTimeout)
public FabricStatus getFabricStatus()
getFabricStatus in interface FabricWorker<T extends java.io.Serializable>public com.liferay.portal.kernel.concurrent.NoticeableFuture<T> getProcessNoticeableFuture()
getProcessNoticeableFuture in interface com.liferay.portal.kernel.process.ProcessChannel<T extends java.io.Serializable>public void setCancel()
public void setException(java.lang.Throwable t)
public void setResult(T result)
public <V extends java.io.Serializable> com.liferay.portal.kernel.concurrent.NoticeableFuture<V> write(com.liferay.portal.kernel.process.ProcessCallable<V> processCallable)
write in interface com.liferay.portal.kernel.process.ProcessChannel<T extends java.io.Serializable>