messageReceived signal not emitted

[monoid-alg]

Hello:

First of all, thank you for your hard work.

I am using your code base to develop a QML plugin. I noticed that the signal messageReceived is not being "emitted". I made the following change and it worked.

Line 576 in amqp_queue.cpp (master branch as of today: April 19, 2013) reads:

                   emit pq_func()->messageReceived(pq_func());

had to change it to

                   QMetaObject::invokeMethod(pq_func(), "messageReceived");

for it to work.

My platform:
Qt 5.0.1
MacOS X 10.8.3 (Mountain Lion)

Thanks.

[cakovacs]

I fixed this problem in the ReceiverLogDirect.h test code. The problem is that the signal is defined with a QAMQP::Queue* argument:

./QAMQP/src/qamqp/amqp_queue.h: void messageReceived(QAMQP::Queue* pQueue)

I fixed it in my branch by adding the argument in the connect statement:
connect(queue_, SIGNAL(messageReceived(QAMQP::Queue_)), this, SLOT(newMessage(QAMQP::Queue_)));

and added it to the slot's argument:
void newMessage(QAMQP::Queue* queue)

I'm not sure why it's passing the queue because the ReceiverLogDirect already has the queue defined in it's data member. Anyway, I added an error check and found that the queue passed always matched the object's queue:

if (queue != queue_) {
qDebug() << "ReceiveLogDirect::newMessage() " << "Ignoring message received from a different queue";
}