func()

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
}