diff --git a/contrib/extension/subscription/subscription.go b/contrib/extension/subscription/subscription.go
index bd9159a880559413f0eea07a0ad5f9f5fc470c7d..acaef9c66881e1489d65ba8c106da2dd20a25e2e 100644
--- a/contrib/extension/subscription/subscription.go
+++ b/contrib/extension/subscription/subscription.go
@@ -92,6 +92,10 @@ type Notifier struct {
 	err chan error
 }
 
+func (n *Notifier) ID() SubID {
+	return n.id
+}
+
 // Notify sends a notification to the client with the given data as payload.
 // If an error occurs the RPC connection is closed and the error is returned.
 func (n *Notifier) Notify(data any) error {