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 boolean equals(Object obj)
equals
in class Object
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 FabricAgent
execute
in interface com.liferay.portal.kernel.process.ProcessExecutor
public void finishStartup(long id)
public FabricStatus getFabricStatus()
getFabricStatus
in interface FabricAgent
public Collection<? extends FabricWorker<?>> getFabricWorkers()
getFabricWorkers
in interface FabricAgent
public int hashCode()
hashCode
in class Object
public NettyFabricWorkerStub<?> takeNettyStubFabricWorker(long id)