Class AggregatorNettyClient
- java.lang.Object
-
- com.alibaba.graphscope.graph.comm.netty.AggregatorNettyClient
-
public class AggregatorNettyClient extends Object
The implementation class which do responsible for all netty-related stuff.
-
-
Field Summary
Fields Modifier and Type Field Description static intMAX_CONNECTION_MILLISECONDS_DEFAULT30 seconds to connect by defaultstatic intSIZE
-
Constructor Summary
Constructors Constructor Description AggregatorNettyClient(ImmutableClassesGiraphConfiguration conf, AggregatorManager aggregatorManager, WorkerInfo workerInfo, Thread.UncaughtExceptionHandler exceptionHandler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()NettyMessagegetResponse()booleanisConnected()Future<NettyMessage>sendMessage(NettyMessage request)
-
-
-
Field Detail
-
MAX_CONNECTION_MILLISECONDS_DEFAULT
public static final int MAX_CONNECTION_MILLISECONDS_DEFAULT
30 seconds to connect by default- See Also:
- Constant Field Values
-
SIZE
public static final int SIZE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
AggregatorNettyClient
public AggregatorNettyClient(ImmutableClassesGiraphConfiguration conf, AggregatorManager aggregatorManager, WorkerInfo workerInfo, Thread.UncaughtExceptionHandler exceptionHandler)
-
-
Method Detail
-
isConnected
public boolean isConnected()
-
sendMessage
public Future<NettyMessage> sendMessage(NettyMessage request)
-
getResponse
public NettyMessage getResponse()
-
close
public void close()
-
-