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.petra.process.ProcessConfig processConfig,
com.liferay.petra.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 Objectpublic <T extends Serializable> FabricWorker<T> execute(com.liferay.petra.process.ProcessConfig processConfig, com.liferay.petra.process.ProcessCallable<T> processCallable)
execute in interface com.liferay.petra.process.ProcessExecutorexecute in interface FabricAgentpublic void finishStartup(long id)
public FabricStatus getFabricStatus()
getFabricStatus in interface FabricAgentpublic Collection<? extends FabricWorker<?>> getFabricWorkers()
getFabricWorkers in interface FabricAgentpublic int hashCode()
hashCode in class Objectpublic NettyFabricWorkerStub<?> takeNettyStubFabricWorker(long id)