diff --git a/internal/daemon/controller/listeners.go b/internal/daemon/controller/listeners.go index d73590945..71a7387b6 100644 --- a/internal/daemon/controller/listeners.go +++ b/internal/daemon/controller/listeners.go @@ -250,7 +250,7 @@ func (c *Controller) configureForCluster(ln *base.ServerListener) (func(), error } }() go func() { - err := handleSecondaryConnection(c.baseContext, metric.InstrumentClusterTrackingListener(reverseGrpcListener, "reverse-grpc"), c.downstreamRoutes, -1) + err := handleSecondaryConnection(c.baseContext, metric.InstrumentClusterTrackingListener(multiplexingReverseGrpcListener, "reverse-grpc"), c.downstreamRoutes, -1) if err != nil { event.WriteError(c.baseContext, op, err, event.WithInfoMsg("handleSecondaryConnection error")) }