diff --git a/ha/heartbeat.go b/ha/heartbeat.go
index e56459f5..a3dd8278 100644
--- a/ha/heartbeat.go
+++ b/ha/heartbeat.go
@@ -6,9 +6,12 @@ import (
 	"crypto/sha1"
 	"encoding/hex"
 	"encoding/json"
+	"fmt"
 	"github.com/Icinga/icingadb/connection"
+	"github.com/Icinga/icingadb/utils"
 	"github.com/go-redis/redis"
 	log "github.com/sirupsen/logrus"
+	"time"
 )
 
 type Environment struct {
@@ -35,7 +38,7 @@ func IcingaHeartbeatListener(rdb *connection.RDBWrapper, chEnv chan *Environment
 	log.Info("Starting heartbeat listener")
 
 	xReadArgs := redis.XReadArgs{
-		Streams: []string{"icinga:stats", "0-0"},
+		Streams: []string{"icinga:stats", fmt.Sprintf("%d-0", utils.TimeToMillisecs(time.Now().Add(-15*time.Second)))},
 		Count:   1,
 		Block:   0,
 	}