public static PubSubMessageQueueManagerImpl getInstance()

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

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

  public static PubSubMessageQueueManagerImpl getInstance() {
    if (instance == null) {
      synchronized (PubSubMessageQueueManagerImpl.class) {
        if (instance == null) {
          instance = new PubSubMessageQueueManagerImpl();
          String topicName = SdrsApplication.getAppConfigProperty(TOPIC_APP_CONFIG_KEY);
          if (topicName == null) {
            logger.error("Topic name is not configured");
          } else {
            try {
              instance.publisher = Publisher.newBuilder(topicName).build();
              logger.info("Pubsub publisher created for topic " + topicName);
            } catch (IOException e) {
              logger.error("Error creating pubsub publisher " + e.getMessage());
            }
          }
        }
      }
    }
    return instance;
  }