src/main/java/com/google/gcs/sdrs/service/mq/PubSubMessageQueueManagerImpl.java [101:110]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      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()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/google/gcs/sdrs/service/mq/PubSubMessageQueueManagerImpl.java [133:142]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      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()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -