parameters: (self, msgs, connection)
docstring: Called by underlying connection transport for each new message received
          @param msgs: message data
          @type msgs: [L{Message}]
docstring_summary: Called by underlying connection transport for each new message received
docstring_tokens: Called by underlying connection transport for each new message received
function: def receive_callback(self, msgs, connection):
          """
          Called by underlying connection transport for each new message received
          @param msgs: message data
          @type msgs: [L{Message}]
          """
          # save reference to avoid lock
          callbacks = self.callbacks
          for msg in msgs:
              if self.statistics_logger:
                  self.statistics_logger.callback(msg, connection.callerid_pub, connection.stat_bytes)
              for cb, cb_args in callbacks:
                  self._invoke_callback(msg, cb, cb_args)
function_tokens: def receive_callback ( self , msgs , connection ) : # save reference to avoid lock callbacks = self . callbacks for msg in msgs : if self . statistics_logger : self . statistics_logger . callback ( msg , connection . callerid_pub , connection . stat_bytes ) for cb , cb_args in callbacks : self . _invoke_callback ( msg , cb , cb_args )