diff --git a/nsq/message.go b/nsq/message.go index 6abc8fe6a..72aff4f87 100644 --- a/nsq/message.go +++ b/nsq/message.go @@ -28,7 +28,7 @@ func NewMessage(id MessageID, body []byte) *Message { return &Message{ Id: id, Body: body, - Timestamp: time.Now().Unix(), + Timestamp: time.Now().UnixNano(), } }