private void shutdownPublisher()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java [147:155]

• 9 lines of code
• 3 McCabe index (conditional complexity)

    private void shutdownPublisher() {
        try {
            if (publisher != null) {
                publisher.shutdown();
            }
        } catch (Exception e) {
            LOG.info("Shutting down Publisher failed.", e);
        }
    }