diff --git a/core/tx_pool.go b/core/tx_pool.go
index 388b40058f1f..f6f2a9b356b9 100644
--- a/core/tx_pool.go
+++ b/core/tx_pool.go
@@ -652,8 +652,8 @@ func (pool *TxPool) add(tx *types.Transaction, local bool) (bool, error) {
 
 		log.Trace("Pooled new executable transaction", "hash", hash, "from", from, "to", tx.To())
 
-		// We've directly injected a replacement transaction, notify subsystems
-		go pool.txFeed.Send(TxPreEvent{tx})
+		// We've directly injected a replacement transaction, notify subsystems.
+		pool.txFeed.Send(TxPreEvent{tx})
 
 		return old != nil, nil
 	}
@@ -747,7 +747,7 @@ func (pool *TxPool) promoteTx(addr common.Address, hash common.Hash, tx *types.T
 	pool.beats[addr] = time.Now()
 	pool.pendingState.SetNonce(addr, tx.Nonce()+1)
 
-	go pool.txFeed.Send(TxPreEvent{tx})
+	pool.txFeed.Send(TxPreEvent{tx})
 }
 
 // AddLocal enqueues a single transaction into the pool if it is valid, marking