com.liferay.portal.fabric.netty.worker

Class NettyFabricWorkerStub<T extends Serializable>

Object

com.liferay.portal.fabric.netty.worker.NettyFabricWorkerStub<T>

All Implemented Interfaces:

com.liferay.petra.process.ProcessChannel<T>, FabricWorker<T>

public class NettyFabricWorkerStub<T extends Serializable>
extends Object
implements FabricWorker<T>

Author:

Shuyang Zhou

Constructor Summary

Constructors

Constructor and Description
NettyFabricWorkerStub(long id, io.netty.channel.Channel channel, Repository<io.netty.channel.Channel> repository, Map<Path,Path> outputPathMap, long rpcRelayTimeout)

Method Summary

Modifier and Type	Method and Description
FabricStatus	getFabricStatus()
com.liferay.petra.concurrent.NoticeableFuture<T>	getProcessNoticeableFuture()
void	setCancel()
void	setException(Throwable t)
void	setResult(T result)
<V extends Serializable> com.liferay.petra.concurrent.NoticeableFuture<V>	write(com.liferay.petra.process.ProcessCallable<V> processCallable)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NettyFabricWorkerStub

public NettyFabricWorkerStub(long id,
                             io.netty.channel.Channel channel,
                             Repository<io.netty.channel.Channel> repository,
                             Map<Path,Path> outputPathMap,
                             long rpcRelayTimeout)

Method Detail

getFabricStatus

public FabricStatus getFabricStatus()

Specified by:

getFabricStatus in interface FabricWorker<T extends Serializable>

getProcessNoticeableFuture

public com.liferay.petra.concurrent.NoticeableFuture<T> getProcessNoticeableFuture()

Specified by:

getProcessNoticeableFuture in interface com.liferay.petra.process.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> com.liferay.petra.concurrent.NoticeableFuture<V> write(com.liferay.petra.process.ProcessCallable<V> processCallable)

Specified by:

write in interface com.liferay.petra.process.ProcessChannel<T extends Serializable>