code: def callback(self, filename, lines, **kwargs):
          
          timestamp = self.get_timestamp(**kwargs)
          if kwargs.get('timestamp', False):
              del kwargs['timestamp']
          
  
          for line in lines:
              try:
                  import warnings
                  with warnings.catch_warnings():
                      warnings.simplefilter('error')
                      m = self.format(filename, line, timestamp, **kwargs)
                      self.logger.debug("Sending message " + m)
                      self.conn.send(destination=self.queue, body=m)    
  
              except Exception, e:
                  self.logger.error(e)
                  try:
                      raise TransportException(e)
                  except AttributeError:
                      raise TransportException('Unspecified exception encountered')
docs: publishes lines one by one to the given topic