diff options
Diffstat (limited to 'weed/mq/topic/local_partition.go')
| -rw-r--r-- | weed/mq/topic/local_partition.go | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index e32fc2398..d1433775a 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -89,12 +89,16 @@ func (p *LocalPartition) Subscribe(clientName string, startPosition log_buffer.M return nil } - startPosition = processedPosition + if processedPosition.Time.UnixNano() != 0 { + startPosition = processedPosition + } processedPosition, isDone, readInMemoryLogErr = p.LogBuffer.LoopProcessLogData(clientName, startPosition, 0, onNoMessageFn, eachMessageFn) if isDone { return nil } - startPosition = processedPosition + if processedPosition.Time.UnixNano() != 0 { + startPosition = processedPosition + } if readInMemoryLogErr == log_buffer.ResumeFromDiskError { continue |