implement subscribe in STOMP

This commit is contained in:
Rémi Heredero 2023-11-29 11:55:52 +01:00
parent 847393cec3
commit 0907d3373c
2 changed files with 13 additions and 6 deletions

View File

@ -26,5 +26,11 @@ int main(int argc, char *argv[]) {
{"login", "sdi10"}, {"login", "sdi10"},
{"passcode", "809c02f36becb0868da98761fe3209f6"} {"passcode", "809c02f36becb0868da98761fe3209f6"}
}).send(socket); }).send(socket);
STOMPFrame(STOMPFrame::MESSAGE, {
{},
}).send(socket);
return application.exec(); return application.exec();
} }

View File

@ -4,13 +4,14 @@ Stomp::Stomp() {
} }
bool Stomp::subscribe(interface::iStompObserver obs) { bool Stomp::subscribe(interface::iStompObserver* obs) {
for(int i = 0; i < MAX_OBSERVER; i++) { for(int i = 0; i < MAX_OBSERVER; i++) {
if (observer_[i] == nullptr) { if (observer_[i] == nullptr) {
observer_[i] = obs; observer_[i] = obs;
return true; return true;
}
} }
return false; }
return false;
}