diff --git a/core/src/server/subscription.rs b/core/src/server/subscription.rs
index a43bd00e4c..c89f7bccde 100644
--- a/core/src/server/subscription.rs
+++ b/core/src/server/subscription.rs
@@ -322,6 +322,11 @@ impl SubscriptionSink {
 		self.method
 	}
 
+	/// Get the connection ID.
+	pub fn connection_id(&self) -> ConnectionId {
+		self.uniq_sub.conn_id
+	}
+
 	/// Send out a response on the subscription and wait until there is capacity.
 	///
 	///