public class NettyFabricAgentStub extends Object implements FabricAgent
| Constructor and Description |
|---|
NettyFabricAgentStub(io.netty.channel.Channel channel,
Repository<io.netty.channel.Channel> repository,
Path remoteRepositoryPath,
long rpcRelayTimeout,
long startupTimeout) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object obj) |
<T extends Serializable> |
execute(com.liferay.portal.kernel.process.ProcessConfig processConfig,
com.liferay.portal.kernel.process.ProcessCallable<T> processCallable) |
void |
finishStartup(long id) |
FabricStatus |
getFabricStatus() |
Collection<? extends FabricWorker<?>> |
getFabricWorkers() |
int |
hashCode() |
NettyFabricWorkerStub<?> |
takeNettyStubFabricWorker(long id) |
public NettyFabricAgentStub(io.netty.channel.Channel channel,
Repository<io.netty.channel.Channel> repository,
Path remoteRepositoryPath,
long rpcRelayTimeout,
long startupTimeout)
public <T extends Serializable> FabricWorker<T> execute(com.liferay.portal.kernel.process.ProcessConfig processConfig, com.liferay.portal.kernel.process.ProcessCallable<T> processCallable)
execute in interface FabricAgentexecute in interface com.liferay.portal.kernel.process.ProcessExecutorpublic void finishStartup(long id)
public FabricStatus getFabricStatus()
getFabricStatus in interface FabricAgentpublic Collection<? extends FabricWorker<?>> getFabricWorkers()
getFabricWorkers in interface FabricAgentpublic NettyFabricWorkerStub<?> takeNettyStubFabricWorker(long id)