MessageReceiver getMessageReceiver()

in src/main/java/com/googlesource/gerrit/plugins/pubsub/PubSubEventSubscriber.java [100:115]

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

  MessageReceiver getMessageReceiver() {
    return (PubsubMessage message, AckReplyConsumer consumer) -> {
      try {
        Event event = eventsDeserializer.deserialize(message.getData().toStringUtf8());
        messageProcessor.accept(event);
        subscriberMetrics.incrementSucceedToConsumeMessage();
      } catch (Exception e) {
        logger.atSevere().withCause(e).log(
            "Exception when consuming message %s from topic %s [message: %s]",
            message.getMessageId(), topic, message.getData().toStringUtf8());
        subscriberMetrics.incrementFailedToConsumeMessage();
      } finally {
        consumer.ack();
      }
    };
  }