(self, publish_msg)
on_md_publish.
on_md_publish.
on_md_publish .
def on_md_publish(self, publish_msg):
        """" on_md_publish. """
        start = datetime.datetime.now()

        topic = publish_msg[0]
        raw_message = publish_msg[1]

        msg = JsonMessage(raw_message)

        if msg.type == 'W':  # Full Refresh
            self.on_md_full_refresh(msg)

        elif msg.type == 'X':  # Incremental
            self.on_md_incremental(msg)

        finish = datetime.datetime.now()
        self.application.log("DEBUG", "PERF", str([ (finish-start).total_seconds(),
                                                    "MarketDataSubscriber.on_md_publish",
                                                    "1",
                                                    [topic, raw_message] ] ) )
def on_md_publish ( self , publish_msg ) : start = datetime . datetime . now ( ) topic = publish_msg [ 0 ] raw_message = publish_msg [ 1 ] msg = JsonMessage ( raw_message ) if msg . type == 'W' : # Full Refresh self . on_md_full_refresh ( msg ) elif msg . type == 'X' : # Incremental self . on_md_incremental ( msg ) finish = datetime . datetime . now ( ) self . application . log ( "DEBUG" , "PERF" , str ( [ ( finish - start ) . total_seconds ( ) , "MarketDataSubscriber.on_md_publish" , "1" , [ topic , raw_message ] ] ) )