public void sendSuccessDeleteMessage()

in src/main/java/com/google/gcs/sdrs/service/mq/PubSubMessageQueueManagerImpl.java [89:112]

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

  public void sendSuccessDeleteMessage(DeleteNotificationMessage msg) throws IOException {
    if (msg == null) {
      logger.warn("Message is null");
      return;
    }
    if (publisher == null) {
      logger.error("Pubsub publisher is null");
      return;
    }

    try {
      SuccessDeleteNotificationEvent avroMessage = msg.convertToAvro();
      if (avroMessage == null) {
        logger.error("Failed to create avro message ");
        return;
      }
      ByteString data = ByteString.copyFrom(convertToJson(avroMessage));
      sendPubSubMessage(data);
    } catch (IOException | NullPointerException e) {
      logger.error(
          String.format("Failed to send message %s,  %s", msg.toString(), e.getMessage()), e);
      throw new IOException(String.format("Failed to send message %s", msg.toString()));
    }
  }