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>