The fake session didn't want to support hasQueuedMessages properly. Also, we need to be subscribed to the correct group to actually get the messages through the session.
@@ -722,7 +722,12 @@ protected:
AsyncReceiveCCSessionTest() :
mccs_(ccspecfile("spec29.spec"), session, NULL, NULL, false, false),
next_flag_(0)
- {}
+ {
+ // This is just to make sure the messages get through the fake
+ // session.
+ session.subscribe("test group");
+ session.subscribe("<ignored>");
+ }
/// \brief Convenience function to queue a request to get a command
/// message.
ModuleCCSession::AsyncRecvRequestID
@@ -207,7 +207,7 @@ FakeSession::reply(ConstElementPtr envelope, ConstElementPtr newmsg) {
bool
FakeSession::hasQueuedMsgs() const {
- return (false);
+ return (messages_ && messages_->size() > 0);
}
ConstElementPtr