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
|
"""
:copyright: Copyright since 2006 by Oliver Schoenborn, all rights reserved.
:license: BSD, see LICENSE.txt for details.
"""
import sys
from pubsub import pub
from pubsub.utils.notification import useNotifyByWriteFile, IgnoreNotificationsMixin
# create one special notification handler that ignores all except
# one type of notification
class MyPubsubNotifHandler(IgnoreNotificationsMixin):
def notifySubscribe(self, pubListener, topicObj, newSub):
newSubMsg = ''
if not newSub:
newSubMsg = ' was already'
msg = 'MyPubsubNotifHandler: listener %s%s subscribed to %s'
print(msg % (pubListener.name(), newSubMsg, topicObj.getName()))
pub.addNotificationHandler(MyPubsubNotifHandler())
# print(all notifications to stdout)
useNotifyByWriteFile(sys.stdout, prefix='NotifyByWriteFile:')
|
