alpha/alpha-spec-saga-akka/src/main/java/org/apache/servicecomb/pack/alpha/spec/saga/akka/channel/kafka/KafkaSagaEventConsumer.java [91:103]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private CompletionStage<String> sendSagaActor(BaseEvent event) {
    try {
      long begin = System.currentTimeMillis();
      metricsService.metrics().doActorReceived();
      // Use the synchronous method call to ensure that Kafka's Offset is set after the delivery is successful.
      Timeout timeout = new Timeout(Duration.create(10, "seconds"));
      Future<Object> future = Patterns.ask(sagaShardRegionActor, event, timeout);
      Await.result(future, timeout.duration());
      long end = System.currentTimeMillis();
      metricsService.metrics().doActorAccepted();
      metricsService.metrics().doActorAvgTime(end - begin);
      return CompletableFuture.completedFuture("OK");
    } catch (Exception ex) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



alpha/alpha-spec-saga-akka/src/main/java/org/apache/servicecomb/pack/alpha/spec/saga/akka/channel/rabbit/RabbitSagaEventConsumer.java [52:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private CompletionStage<String> sendSagaActor(BaseEvent event) {
        try {
            long begin = System.currentTimeMillis();
            metricsService.metrics().doActorReceived();
            Timeout timeout = new Timeout(Duration.create(10, "seconds"));
            Future<Object> future = Patterns.ask(sagaShardRegionActor, event, timeout);
            Await.result(future, timeout.duration());
            long end = System.currentTimeMillis();
            metricsService.metrics().doActorAccepted();
            metricsService.metrics().doActorAvgTime(end - begin);
            return CompletableFuture.completedFuture("OK");
        } catch (Exception ex) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -