private void sendToPubSub()

in hive-metastore-listener/src/main/java/com/google/datacatalog_connectors/hive/metastore/HiveMetastoreListener.java [128:146]

• 17 lines of code
• 4 McCabe index (conditional complexity)

  private void sendToPubSub(Object request) {
    try {

      PubSubWrapper pubsub = new PubSubWrapper(PROJECT_ID);
      ObjectMapper objMapper = new ObjectMapper();

      String message = objMapper.writeValueAsString(request);
      List<String> messageIds = pubsub.publishMessage(TOPIC_ID,
          message);
      if (messageIds != null) {
        for (String messageId : messageIds) {
          LOGGER.info("Published with a message id: " + messageId);
        }
      }
    } catch (Exception e) {
      LOGGER.error("Exception Publishing to Pub/Sub: ", e);
      throw new RuntimeException(e);
    }
  }