jessequ
/
qamqp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update Readme

This commit is contained in:
Alexey Shcherbakov 2013-04-28 11:13:57 +06:00
parent 1a05e873cb
commit 754c1fd480
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
README.md
View File

@ -73,7 +73,7 @@ Usage
queue_ = client_->createQueue("test.my_queue", exchange_->channelNumber()); queue_ = client_->createQueue("test.my_queue", exchange_->channelNumber());
connect(queue_, SIGNAL(declared()), this, SLOT(declared())); connect(queue_, SIGNAL(declared()), this, SLOT(declared()));
connect(queue_, SIGNAL(messageRecieved()), this, SLOT(newMessage())); connect(queue_, SIGNAL(messageReceived(QAMQP::Queue * )), this, SLOT(newMessage(QAMQP::Queue *)));
} }
@ -92,9 +92,8 @@ Usage
queue_->consume(QAMQP::Queue::coNoAck); queue_->consume(QAMQP::Queue::coNoAck);
} }
void Test::newMessage() void Test::newMessage(QAMQP::Queue * q)
{ {
QAMQP::Queue * q = qobject_cast<QAMQP::Queue *>(sender());
while (q->hasMessage()) while (q->hasMessage())
{ {
QAMQP::MessagePtr message = q->getMessage(); QAMQP::MessagePtr message = q->getMessage();