diff --git a/nsqd/channel.go b/nsqd/channel.go index 073a80803..d7b56581e 100644 --- a/nsqd/channel.go +++ b/nsqd/channel.go @@ -214,7 +214,11 @@ func (c *Channel) Empty() error { } finish: - // TODO: (WAL) reset cursor + idx, err := c.cursor.Reset() + if err != nil { + return err + } + c.rs.AddRange(Range{Low: c.rs.Ranges[0].Low, High: int64(idx)}) return nil }