alanxz/SimpleAmqpClient — pull request #62 by RafalGoslawski (2013-08-01 15:14:01+00:00)
Title: Add Channel::CancelConsume() to cancel BasicConsumeMessage

This method cancels BasicConsumeMessage as if it timed out immediately.
Internaly it uses pipe() to listen to in select() call in
GetNextFrameFromBroker(). This way different thread can write a byte
to the pipe, causing BasicConsumeMessage to timeout immetiately.