public final T process()

in app/common/src/main/java/com/googlecodesamples/cloud/jss/common/action/BaseAction.java [107:114]

• 7 lines of code
• 1 McCabe index (conditional complexity)

  public final T process(PubsubMessage message, AckReplyConsumer consumer)
      throws InterruptedException, IOException {
    logger.info("process received message, message: {}", PubSubUtil.getMessageData(message));
    // Sleep for a random amount to simulate the processing time.
    float processTime = PubSubUtil.genProcessTime();
    Thread.sleep((long) (processTime * 1000));
    return respond(consumer, message, processTime, message.getPublishTime());
  }