diff --git a/swarm/network/stream/delivery.go b/swarm/network/stream/delivery.go
index 33007a6109..bc4f1f665f 100644
--- a/swarm/network/stream/delivery.go
+++ b/swarm/network/stream/delivery.go
@@ -295,13 +295,12 @@ func (d *Delivery) RequestFromPeers(ctx context.Context, req *network.Request) (
 	// this span will finish only when delivery is handled (or times out)
 	ctx = context.WithValue(ctx, tracing.StoreLabelId, "stream.send.request")
 	ctx = context.WithValue(ctx, tracing.StoreLabelMeta, fmt.Sprintf("%v.%v", sp.ID(), req.Addr))
-	ctx = tracing.StartSaveSpan(ctx)
 	log.Trace("request.from.peers", "peer", sp.ID(), "ref", req.Addr)
-	err := sp.Send(ctx, &RetrieveRequestMsg{
+	err := sp.SendPriority(ctx, &RetrieveRequestMsg{
 		Addr:      req.Addr,
 		SkipCheck: req.SkipCheck,
 		HopCount:  req.HopCount,
-	})
+	}, Top)
 	if err != nil {
 		return nil, nil, err
 	}
diff --git a/swarm/network/stream/peer.go b/swarm/network/stream/peer.go
index bbfc5a2b47..152814bd4f 100644
--- a/swarm/network/stream/peer.go
+++ b/swarm/network/stream/peer.go
@@ -154,7 +154,7 @@ func (p *Peer) Deliver(ctx context.Context, chunk storage.Chunk, priority uint8,
 	}
 
 	ctx = context.WithValue(ctx, "stream_send_tag", nil)
-	return p.Send(ctx, msg)
+	return p.SendPriority(ctx, msg, priority)
 }
 
 // SendPriority sends message to the peer using the outgoing priority queue