private MessageSender buildSender()

in omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/LoadBalanceContextBuilder.java [98:122]

• 25 lines of code
• 3 McCabe index (conditional complexity)

  private MessageSender buildSender(
      String address, ManagedChannel channel, AlphaClusterConfig clusterConfig,
      ServiceConfig serviceConfig, LoadBalanceContext loadContext) {
    switch (transactionType) {
      case TCC:
        return new GrpcTccClientMessageSender(
            serviceConfig,
            channel,
            address,
            clusterConfig.getTccMessageHandler(),
            loadContext);
      case SAGA:
        return new GrpcSagaClientMessageSender(
            address,
            channel,
            clusterConfig.getMessageSerializer(),
            clusterConfig.getMessageDeserializer(),
            serviceConfig,
            clusterConfig.getMessageHandler(),
            loadContext
        );
        default:
    }
      return null;
  }