code: def send_message(host, data, timeout=None, properties=None):
      
      channel = _get_channel(host, timeout)
  
      if not properties:
          properties = pika.BasicProperties(
              content_type="application/json",
              delivery_mode=2,
              headers={"UUID": str(uuid.uuid4())}
          )
  
      parameters = settings.get_amqp_settings()[host]
  
      channel.basic_publish(
          exchange=parameters["exchange"],
          routing_key=parameters["in_key"],
          properties=properties,
          body=data
      )
docs: Send message to given `host`.
  
      Args:
          host (str): Specified host: aleph/ftp/whatever available host.
          data (str): JSON data.
          timeout (int, default None): How much time wait for connection.