diff --git a/downstream.go b/downstream.go
index 11bf43d..9cb9b39 100644
--- a/downstream.go
+++ b/downstream.go
@@ -1231,7 +1231,7 @@ func (dc *downstreamConn) handleMessageRegistered(msg *irc.Message) error {
 
 			uc.appendLog(upstreamName, echoMsg)
 
-			uc.network.ring.Produce(echoMsg)
+			uc.produce(echoMsg)
 		}
 	case "NOTICE":
 		var targetsStr, text string
diff --git a/upstream.go b/upstream.go
index d779979..3bb6747 100644
--- a/upstream.go
+++ b/upstream.go
@@ -247,7 +247,7 @@ func (uc *upstreamConn) handleMessage(msg *irc.Message) error {
 		return nil
 	case "NOTICE":
 		if msg.Prefix.User == "" && msg.Prefix.Host == "" { // server message
-			uc.network.ring.Produce(msg)
+			uc.produce(msg)
 		} else { // regular user NOTICE
 			var entity, text string
 			if err := parseMessageParams(msg, &entity, &text); err != nil {
@@ -260,7 +260,7 @@ func (uc *upstreamConn) handleMessage(msg *irc.Message) error {
 			}
 			uc.appendLog(target, msg)
 
-			uc.network.ring.Produce(msg)
+			uc.produce(msg)
 		}
 	case "CAP":
 		var subCmd string
@@ -1135,7 +1135,7 @@ func (uc *upstreamConn) handleMessage(msg *irc.Message) error {
 		}
 		uc.appendLog(target, msg)
 
-		uc.network.ring.Produce(msg)
+		uc.produce(msg)
 	case "INVITE":
 		var nick string
 		var channel string
@@ -1363,6 +1363,10 @@ func (uc *upstreamConn) appendLog(entity string, msg *irc.Message) {
 	}
 }
 
+func (uc *upstreamConn) produce(msg *irc.Message) {
+	uc.network.ring.Produce(msg)
+}
+
 func (uc *upstreamConn) updateAway() {
 	away := true
 	uc.forEachDownstream(func(*downstreamConn) {