1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
"""
This is the subscriber for the 'many topics' messages example.
For code with more explanations, see the regular 'weather' message example code.
"""
from __future__ import print_function
import os
import time
import threading
import Pyro4
from operator import itemgetter
from messagebus.messagebus import Subscriber
Pyro4.config.AUTOPROXY = True
@Pyro4.expose
class Subber(Subscriber):
def init_counters(self, topics):
self.message_counter = {}
self.last_message = {}
for t in topics:
self.message_counter[t] = 0
self.last_message[t] = None
def consume_message(self, topic, message):
self.message_counter[topic] += 1
self.last_message[topic] = message
def clear_screen():
os.system(['clear', 'cls'][os.name == 'nt'])
subber = Subber()
d = Pyro4.Daemon()
d.register(subber)
daemon_thread = threading.Thread(target=d.requestLoop)
daemon_thread.daemon = True
daemon_thread.start()
# mass subscribe to all available topics
topics = list(sorted(subber.bus.topics()))
subber.init_counters(topics)
for t in topics:
subber.bus.subscribe(t, subber)
# show a table of the active topics on the bus
while True:
clear_screen()
print(time.ctime(), "-- active topics on the messagebus:")
print("{:20} : {:5} {} {}".format("topic", "count", "last_recv", "last message data"))
for topic, count in sorted(subber.message_counter.items(), key=itemgetter(1), reverse=True):
msg = subber.last_message[topic]
if msg:
print("{:20} : {:5d} - {} {!r:.20}".format(topic, count, msg.created.time(), msg.data))
else:
print("{:20} : {:5d}".format(topic, count))
print("(restart me to refresh the list of topics)")
time.sleep(1)
|
