private void shutdownManagedChannel()

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

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

    private void shutdownManagedChannel() {
        if (managedChannel == null) {
            return;
        }
        try {
            managedChannel.shutdownNow();
            managedChannel.awaitTermination(1000L, TimeUnit.MILLISECONDS);
        } catch (Exception e) {
            LOG.info("Shutting down ManagedChannel failed.", e);
        }
    }