import paho.mqtt.client as mqtt
from paho.mqtt.enums import CallbackAPIVersion #v2

#def on_publish(client, userdate, mid): # VERSION1
def on_publish(client, userdate, mid, reason_code, properties): # VERSION2
    print("Data was published")


client = mqtt.Client(CallbackAPIVersion.VERSION2,'demo_unimib_pub')
#client.connect('broker.emqx.io')
client.connect('test.mosquitto.org')
client.on_publish = on_publish

while True:
    msg = input("Message: ")
    if msg == "end":
        break
    client.publish('skenz_room123/chat', msg)