Skip to content

Commit fa6ced7

Browse files
authored
Merge pull request #80 from moredure/master
Update message.go
2 parents 8baf124 + fc9c221 commit fa6ced7

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

message.go

+10
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package stomp
22

33
import (
4+
"io"
45
"github.com/go-stomp/stomp/frame"
56
)
67

@@ -47,3 +48,12 @@ func (msg *Message) ShouldAck() bool {
4748

4849
return msg.Subscription.AckMode() != AckAuto
4950
}
51+
52+
func (msg *Message) Read(p []byte) (int, error) {
53+
if len(msg.Body) == 0 {
54+
return 0, io.EOF
55+
}
56+
n := copy(p, msg.Body)
57+
msg.Body = msg.Body[n:]
58+
return n, nil
59+
}

0 commit comments

Comments
 (0)