[chore]move googlecloudpubsubreceiver to generated lifecycle tests (o…

…pen-telemetry#29940) Related to open-telemetry#27850
Frapschen · Dec 18, 2023 · 9ebd834 · 9ebd834
1 parent 7a09497
commit 9ebd834
Show file tree

Hide file tree

Showing 3 changed files with 114 additions and 0 deletions.
diff --git a/receiver/googlecloudpubsubreceiver/generated_component_test.go b/receiver/googlecloudpubsubreceiver/generated_component_test.go
diff --git a/receiver/googlecloudpubsubreceiver/metadata.yaml b/receiver/googlecloudpubsubreceiver/metadata.yaml
@@ -7,3 +7,11 @@ status:
   distributions: [observiq, sumo]
   codeowners:
     active: [alexvanboxel]
+
+tests:
+  config:
+    project: my-project
+    user_agent: user-agent
+    timeout: 20s
+    subscription: projects/my-project/subscriptions/otlp-subscription
+  skip_lifecycle: true
diff --git a/receiver/googlecloudpubsubreceiver/receiver.go b/receiver/googlecloudpubsubreceiver/receiver.go
@@ -111,6 +111,9 @@ func (receiver *pubsubReceiver) Start(ctx context.Context, _ component.Host) err
 }
 
 func (receiver *pubsubReceiver) Shutdown(_ context.Context) error {
+	if receiver.handler == nil {
+		return nil
+	}
 	receiver.logger.Info("Stopping Google Pubsub receiver")
 	receiver.handler.CancelNow()
 	receiver.logger.Info("Stopped Google Pubsub receiver")