Zeebe Gateway源码之StandaloneGateway创建BrokerClient详解(三)

private BrokerClient createBrokerClient(final GatewayCfg config) {
	return new BrokerClientImpl(
		config,
		// *********************************************************
		// MessagingService是atomix基于Netty组件之上,进行一消息处理器
		// *********************************************************
		atomixCluster.getMessagingService(),
		// *********************************************************
		// ClusterMembershipService主要用于获取成员列表,呆会会扔出相关的API出来
		// *********************************************************
		atomixCluster.getMembershipService(),
		// *********************************************************
		// ClusterEventService是集群事件服务,是atomix为集群的机器提供通信的一个组件,主要用于广播以及订阅信息
		// *********************************************************
		atomixCluster.getEventService(),
		// *********************************************************
		// ActorScheduler在上一小节剖析过了,他主要是两组线程池(CPU密集型和IO密集型)
		// *********************************************************
		actorScheduler,
		false);
}

public interface BrokerClient extends AutoCloseable {
	// 发送请求
	<T> CompletableFuture<BrokerResponse<T>> sendRequest(BrokerRequest<T> request);
	
	// 发送请求,并附加上超时
	<T> CompletableFuture<BrokerResponse<T>> sendRequest(BrokerRequest<T> request, Duration requestTimeout);
	
	// 发送请求,并重试
	<T> CompletableFuture<BrokerResponse<T>> sendRequestWithRetry(BrokerRequest<T> request);
	
	// 发送请求,并重试,并附加上超时
	<T> CompletableFuture<BrokerResponse<T>> sendRequestWithRetry(BrokerRequest<T> request, Duration requestTimeout);
	
	<T> void sendRequestWithRetry(BrokerRequest<T> request,BrokerResponseConsumer<T> responseConsumer,Consumer<Throwable> throwableConsumer);
	
	// 获取Broker集群信息
	BrokerTopologyManager getTopologyManager();
	
	// 没太看明白这是啥 
	void subscribeJobAvailableNotification(String topic, Consumer<String> handler);
}