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