docs: def body(self):
          """
          This method handles AMQP connection details and reacts to FTP events by
          sending messages to output queue.
          """
          self.connection = pika.BlockingConnection(self.connection_param)
          self.channel = self.connection.channel()
  
          print "Monitoring file '%s'." % self.ftp_extended_log
  
          file_iter = process_log(
              sh.tail("-f", self.ftp_extended_log, _iter=True)
          )
          for import_request in file_iter:
              self.sendMessage(
                  exchange=self.output_exchange,
                  routing_key=self.output_key,
                  message=serializers.serialize(import_request),
                  UUID=str(uuid.uuid1())
              )