assert response.status_code == 200, response.text
    assert response.json() == {"message": "Message sent"}
    with open("./log.txt") as f:

    assert response.status_code == 200, response.text
    assert response.json() == {"message": "Message sent"}
    with open("./log.txt") as f:

  # qos level is set to 1
  client.subscribe("minio", 1)

def on_message(client, userdata, msg):
    print(msg.payload)

# client_id is a randomly generated unique ID for the mqtt broker to identify the connection.
client = mqtt.Client(client_id="myclientid",clean_session=False)

client.on_connect = on_connect
client.on_message = on_message

client.connect("localhost",1883,60)
client.loop_forever()
```

      <match value="\nReturn-Path:" type="string" offset="2:9"/>
      <match value="\nFrom:" type="string" offset="2:9"/>
      <match value="\nReceived:" type="string" offset="2:9"/>
      <match value="\nMessage-ID:" type="string" offset="2:9"/>
      <match value="\nDate:" type="string" offset="2:9"/>
    </magic>
    <glob pattern="*.emlx"/>
    <sub-class-of type="text/x-tika-text-based-message"/>
  </mime-type>