Revize 8037bfb7
Přidáno uživatelem Martin Forejt před téměř 4 roky(ů)
aswi2021vochomurka/service/subscriber_callback.py | ||
---|---|---|
3 | 3 |
|
4 | 4 |
class SubscriberCallback: |
5 | 5 |
def onConnected(self): raise NotImplementedError |
6 |
""" called when subscriber successfully connect to broker """ |
|
6 | 7 |
|
7 | 8 |
def onDisconnected(self): raise NotImplementedError |
9 |
""" called when subscriber disconnect from broker """ |
|
8 | 10 |
|
9 | 11 |
def onError(self): raise NotImplementedError |
12 |
""" called when some error occurred """ |
|
10 | 13 |
|
11 | 14 |
def onMessage(self, message: Message): raise NotImplementedError |
15 |
""" called when new message received """ |
|
16 |
|
|
17 |
def onCloseTopic(self, topic: str): raise NotImplementedError |
|
18 |
""" called if no message has been received for a long time for topic """ |
aswi2021vochomurka/view/main_view.py | ||
---|---|---|
38 | 38 |
def onMessage(self, message: Message): |
39 | 39 |
self.newMessage.emit(message.topic) |
40 | 40 |
|
41 |
def onCloseTopic(self, topic: str): |
|
42 |
pass |
|
43 |
|
|
41 | 44 |
|
42 | 45 |
class MainView(QMainWindow): |
43 | 46 |
worker: Worker = None |
Také k dispozici: Unified diff
Re #8566 - add onCloseTopic method to callback