diff --git a/core/services/jobs/sse.go b/core/services/jobs/sse.go
index f66d5ea33..fe2981ec2 100644
--- a/core/services/jobs/sse.go
+++ b/core/services/jobs/sse.go
@@ -10,7 +10,7 @@ import (
 	"github.com/labstack/echo/v4"
 )
 
-// SSEBridge provides an HTTP handler that bridges NATS progress events to SSE.
+// SSEHandler provides an HTTP handler that bridges NATS progress events to SSE.
 // This follows the notetaker pattern: subscribe to NATS, forward to SSE client.
 func (d *Dispatcher) SSEHandler() echo.HandlerFunc {
 	return func(c echo.Context) error {
diff --git a/core/services/messaging/subjects.go b/core/services/messaging/subjects.go
index 89fab4b6b..e72222fc2 100644
--- a/core/services/messaging/subjects.go
+++ b/core/services/messaging/subjects.go
@@ -292,7 +292,7 @@ func SubjectCacheInvalidateCollection(name string) string {
 	return "cache.invalidate.collections." + sanitizeSubjectToken(name)
 }
 
-// SyncedMap State Sync (Pub/Sub — broadcast to all frontends)
+// SubjectSyncStateDelta returns the SyncedMap state sync subject (Pub/Sub — broadcast to all frontends).
 //
 // The reusable syncstate.SyncedMap component publishes a {op,key,value} delta on
 // this subject whenever a replica mutates a piece of cross-replica in-memory