(self, stage: str, topicObj: Topic, pubListener: Listener = None)
Stage must be 'pre' or 'post'. Note that any pubsub sendMessage
        operation resulting from this notification (which sends a message; 
        listener could handle by sending another message!) will NOT themselves
        lead to a send notification.
Stage must be 'pre' or 'post'. Note that any pubsub sendMessage
        operation resulting from this notification (which sends a message; 
        listener could handle by sending another message!) will NOT themselves
        lead to a send notification.
Stage must be pre or post . Note that any pubsub sendMessage operation resulting from this notification ( which sends a message ; listener could handle by sending another message! ) will NOT themselves lead to a send notification .
def notifySend(self, stage: str, topicObj: Topic, pubListener: Listener = None):
        """
        Stage must be 'pre' or 'post'. Note that any pubsub sendMessage
        operation resulting from this notification (which sends a message; 
        listener could handle by sending another message!) will NOT themselves
        lead to a send notification.
        """
        if (self._pubTopic is None) or self.__sending:
            return

        sendMsgTopic = self._pubTopic.getSubtopic('sendMessage')
        if stage == 'pre' and (topicObj is sendMsgTopic):
            msg = 'Not allowed to send messages of topic %s' % topicObj.getName()
            raise ValueError(msg)

        self.__doNotification(sendMsgTopic, dict(topic=topicObj, stage=stage))
def notifySend ( self , stage : str , topicObj : Topic , pubListener : Listener = None ) : if ( self . _pubTopic is None ) or self . __sending : return sendMsgTopic = self . _pubTopic . getSubtopic ( 'sendMessage' ) if stage == 'pre' and ( topicObj is sendMsgTopic ) : msg = 'Not allowed to send messages of topic %s' % topicObj . getName ( ) raise ValueError ( msg ) self . __doNotification ( sendMsgTopic , dict ( topic = topicObj , stage = stage ) )