diff --git a/cmd/streams/stream.go b/cmd/streams/stream.go
index 0a675b1f..2c175913 100644
--- a/cmd/streams/stream.go
+++ b/cmd/streams/stream.go
@@ -198,8 +198,12 @@ producers:
 //}
 
 func (s *Stream) MarshalJSON() ([]byte, error) {
+	if !s.mu.TryLock() {
+		log.Warn().Msgf("[streams] json locked")
+		return []byte(`null`), nil
+	}
+
 	var v []interface{}
-	s.mu.Lock()
 	for _, prod := range s.producers {
 		if prod.element != nil {
 			v = append(v, prod.element)