Skip to content

Commit ff456d7

Browse files
committed
fixing msgdef type error
1 parent 668e1f4 commit ff456d7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

store/file/filestore.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -361,10 +361,11 @@ func (store *fileStore) SaveMessageAndIncrNextSenderMsgSeqNum(seqNum int, msg []
361361
}
362362

363363
func (store *fileStore) getMessage(seqNum int) (msg []byte, found bool, err error) {
364-
msgInfo, found := store.offsets.Load(seqNum)
364+
msgInfoTemp, found := store.offsets.Load(seqNum)
365365
if !found {
366366
return
367367
}
368+
msgInfo := msgInfoTemp.(msgDef)
368369

369370
msg = make([]byte, msgInfo.size)
370371
if _, err = store.bodyFile.ReadAt(msg, msgInfo.offset); err != nil {

0 commit comments

Comments
 (0)