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
|
"""
This is a subscriber meant for the 'weather' messages example.
It uses a callback to process incoming messages.
"""
import sys
import Pyro5.errors
from Pyro5.api import expose, Daemon
from messagebus.messagebus import Subscriber
sys.excepthook = Pyro5.errors.excepthook
@expose
class Subber(Subscriber):
def consume_message(self, topic, message):
# This callback-method is called automatically when a message arrives on the bus.
print("\nGOT MESSAGE:")
print(" topic:", topic)
print(" msgid:", message.msgid)
print(" created:", message.created)
print(" data:", message.data)
hostname = input("hostname to bind on (empty=localhost): ").strip() or "localhost"
# create a messagebus subscriber that uses automatic message retrieval (via a callback)
subber = Subber()
d = Daemon(host=hostname)
d.register(subber)
topics = subber.bus.topics()
print("Topics on the bus: ", topics)
print("Subscribing to weather-forecast.")
subber.bus.subscribe("weather-forecast", subber)
# note: we subscribe on the bus *after* registering the subber as a Pyro object
# this results in Pyro automatically making a proxy for the subber
print("Subscribed on weather-forecast")
d.requestLoop()
|
