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.
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
bool
FakeSession::hasQueuedMsgs() const {
- return (false);
+ return (messages_ && messages_->size() > 0);
}
ConstElementPtr