com.liferay.portal.fabric.netty.agent

Class NettyFabricAgentStub

java.lang.Object

com.liferay.portal.fabric.netty.agent.NettyFabricAgentStub

All Implemented Interfaces:

com.liferay.petra.process.ProcessExecutor, FabricAgent

public class NettyFabricAgentStub
extends java.lang.Object
implements FabricAgent

Author:

Shuyang Zhou

Constructor Summary

Constructors

Constructor and Description
NettyFabricAgentStub(io.netty.channel.Channel channel, Repository<io.netty.channel.Channel> repository, java.nio.file.Path remoteRepositoryPath, long rpcRelayTimeout, long startupTimeout)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
<T extends java.io.Serializable> FabricWorker<T>	execute(com.liferay.petra.process.ProcessConfig processConfig, com.liferay.petra.process.ProcessCallable<T> processCallable)
void	finishStartup(long id)
FabricStatus	getFabricStatus()
java.util.Collection<? extends FabricWorker<?>>	getFabricWorkers()
int	hashCode()
NettyFabricWorkerStub<?>	takeNettyStubFabricWorker(long id)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyFabricAgentStub

public NettyFabricAgentStub(io.netty.channel.Channel channel,
                            Repository<io.netty.channel.Channel> repository,
                            java.nio.file.Path remoteRepositoryPath,
                            long rpcRelayTimeout,
                            long startupTimeout)

Method Detail

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

execute

public <T extends java.io.Serializable> FabricWorker<T> execute(com.liferay.petra.process.ProcessConfig processConfig,
                                                                com.liferay.petra.process.ProcessCallable<T> processCallable)

Specified by:

execute in interface com.liferay.petra.process.ProcessExecutor

Specified by:

execute in interface FabricAgent

finishStartup

public void finishStartup(long id)

getFabricStatus

public FabricStatus getFabricStatus()

Specified by:

getFabricStatus in interface FabricAgent

getFabricWorkers

public java.util.Collection<? extends FabricWorker<?>> getFabricWorkers()

Specified by:

getFabricWorkers in interface FabricAgent

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

takeNettyStubFabricWorker

public NettyFabricWorkerStub<?> takeNettyStubFabricWorker(long id)