public Result invoke()

in omega/omega-transport/omega-transport-dubbo/src/main/java/org/apache/servicecomb/pack/omega/transport/dubbo/PackDubboConsumerFilter.java [53:69]

• 16 lines of code
• 5 McCabe index (conditional complexity)

  public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
    if (omegaContext != null) {
      invocation.getAttachments().put(GLOBAL_TX_ID_KEY, omegaContext.globalTxId());
      invocation.getAttachments().put(LOCAL_TX_ID_KEY, omegaContext.localTxId());
    }
    if (omegaContext != null && omegaContext.globalTxId() != null) {
      LOG.debug("Added {} {} and {} {} to dubbo invocation", new Object[] {GLOBAL_TX_ID_KEY, omegaContext.globalTxId(),
          LOCAL_TX_ID_KEY, omegaContext.localTxId()});
    } else {
      LOG.debug("Cannot inject transaction ID, as the OmegaContext is null or cannot get the globalTxId.");
    }

    if (invoker != null) {
      return invoker.invoke(invocation);
    }
    return null;
  }