Skip to content

Commit

Permalink
Merge pull request #1030 from bobrik/partial-version
Browse files Browse the repository at this point in the history
Do not choke on MessageSet without version
  • Loading branch information
eapache committed Feb 2, 2018
2 parents 75fd5ac + 885c1b0 commit a5eaad6
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions message_set.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,10 @@ func (ms *MessageSet) decode(pd packetDecoder) (err error) {
for pd.remaining() > 0 {
magic, err := magicValue(pd)
if err != nil {
if err == ErrInsufficientData {
ms.PartialTrailingMessage = true
return nil
}
return err
}

Expand Down

0 comments on commit a5eaad6

Please sign in to comment.