diff --git a/filters.go b/filters.go
index 055263e..64ad41a 100644
--- a/filters.go
+++ b/filters.go
@@ -75,7 +75,7 @@ func readMapFromDisk(persistenceFilePath string, logger *log.Logger) map[EventKe
 	data := make([]PersistenceRecord, 0)
 	err = dec.Decode(&data)
 	if err != nil {
-		logger.Println("LastSeenFilter: Error reading persistence file", persistenceFilePath, "from disk:", err, ". Discarding and starting over.")
+		logger.Println("Error reading persistence file", persistenceFilePath, "from disk:", err, ". Discarding and starting over.")
 		return lastSeen
 	}
 	for _, readData := range data {
diff --git a/main.go b/main.go
index 3f2f941..7176f84 100644
--- a/main.go
+++ b/main.go
@@ -98,7 +98,7 @@ func main() {
 
 	tgSender := TgSender{bot}
 	go tgSenderWorker(tgEvents, tgSender, &wg, sleeper, log.New(os.Stderr, "TgSender", log.Lmicroseconds))
-	for e := range s.Events {
+	for e := range FilterByLastSeen(s.Events, "hs_wro_last_seen.bin", log.New(os.Stderr, "FilterByLastSeen", log.Lmicroseconds)) {
 		logger.Print("Received change from SATEL: ", e)
 		sendTgMessage(tgEvents, fmt.Sprint("Change from SATEL: type:", e.Type, ", index:", e.Index, ", value:", e.Value), chatIds)
 	}