diff --git a/downstream.go b/downstream.go
index 8fccfed..9605998 100644
--- a/downstream.go
+++ b/downstream.go
@@ -727,7 +727,7 @@ func (dc *downstreamConn) register() error {
 			}
 		}
 
-		historyName := dc.username
+		historyName := dc.rawUsername
 
 		var seqPtr *uint64
 		if firstDownstream {