in queue.go [150:160]
func (p *MNSQueue) PeekMessage(respChan chan MessageReceiveResponse, errChan chan error) {
p.qpsMonitor.checkQPS()
resp := MessageReceiveResponse{}
_, err := send(p.client, p.decoder, GET, nil, nil, fmt.Sprintf("queues/%s/%s?peekonly=true", p.name, "messages"), &resp)
if err != nil {
errChan <- err
} else {
respChan <- resp
}
return
}