fix(functions): add code to shutdown publisher to free up resources (#10027)

Author: alarconesparza

functions/pubsub/publish-message/src/main/java/functions/PublishMessage.java

@@ -30,6 +30,7 @@
 import java.nio.charset.StandardCharsets;
 import java.util.Optional;
 import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -40,7 +41,8 @@ public class PublishMessage implements HttpFunction {
   private static final Logger logger = Logger.getLogger(PublishMessage.class.getName());
 
   @Override
-  public void service(HttpRequest request, HttpResponse response) throws IOException {
+  public void service(HttpRequest request, HttpResponse response)
+      throws IOException, InterruptedException {
     Optional<String> maybeTopicName = request.getFirstQueryParameter("topic");
     Optional<String> maybeMessage = request.getFirstQueryParameter("message");
 
@@ -72,6 +74,12 @@ public void service(HttpRequest request, HttpResponse response) throws IOExcepti
     } catch (InterruptedException | ExecutionException e) {
       logger.log(Level.SEVERE, "Error publishing Pub/Sub message: " + e.getMessage(), e);
       responseMessage = "Error publishing Pub/Sub message; see logs for more info.";
+    } finally {
+      if (publisher != null) {
+        // When finished with the publisher, shutdown to free up resources.
+        publisher.shutdown();
+        publisher.awaitTermination(1, TimeUnit.MINUTES);
+      }
     }
 
     responseWriter.write(responseMessage);

functions/pubsub/publish-message/src/test/java/functions/PublishMessageTest.java

@@ -70,12 +70,12 @@ public void beforeTest() throws IOException {
   }
 
   @Test
-  public void functionsPubsubPublish_shouldFailWithoutParameters() throws IOException {
+  public void functionsPubsubPublish_shouldFailWithoutParameters()
+      throws IOException, InterruptedException {
     new PublishMessage().service(request, response);
 
     writerOut.flush();
-    assertThat(responseOut.toString()).isEqualTo(
-        "Missing 'topic' and/or 'message' parameter(s).");
+    assertThat(responseOut.toString()).isEqualTo("Missing 'topic' and/or 'message' parameter(s).");
   }
 
   @Test
@@ -86,8 +86,8 @@ public void functionsPubsubPublish_shouldPublishMessage() throws Exception {
     new PublishMessage().service(request, response);
 
     writerOut.flush();
-    assertThat(logHandler.getStoredLogRecords().get(0).getMessage()).isEqualTo(
-        "Publishing message to topic: " + FUNCTIONS_TOPIC);
+    assertThat(logHandler.getStoredLogRecords().get(0).getMessage())
+        .isEqualTo("Publishing message to topic: " + FUNCTIONS_TOPIC);
     assertThat(responseOut.toString()).isEqualTo("Message published.");
   }
 }