public void publishMsg()

in app/common/src/main/java/com/googlecodesamples/cloud/jss/common/service/BasePublisherService.java [68:83]

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

  public void publishMsg(PubsubMessage message) throws InterruptedException, ExecutionException {
    int messageCount = totalMessage.incrementAndGet();
    String threadName = Thread.currentThread().getName();
    String topicName = publisher.getTopicName().toString();
    long publishTime = System.currentTimeMillis();

    logger.info("thread: {}, topic: {}, messageCount: {}", threadName, topicName, messageCount);

    // Publish a message, then wait for a server-assigned message id.
    ApiFuture<String> future = publisher.publish(message);
    String result = future.get();
    logger.info("message: {}, callback received: {}", PubSubUtil.getMessageData(message), result);

    long callBackTime = System.currentTimeMillis();
    logger.info("message: {}, process time: {}", result, (callBackTime - publishTime));
  }