#!/usr/bin/env python
# -*- coding: utf-8 -*-

import paho.mqtt.client as mqtt
import json

host = 'std1.mqtt.shiguredo.jp'
port = 8883
#port = 1883
req_topic = '{request_topic}'
USERNAME = '{username}'
PASSWORD = '{password}'


def on_connect(client, userdata, flags, respons_code):
    print('status {0}'.format(respons_code))
    client.subscribe(req_topic)


def on_message(client, userdata, msg):
    # print(msg.topic + ' ' + str(msg.payload))
    payload = json.loads(msg.payload)
    response = ''
    print(payload)
    # client.publish(res_topic, json.dumps(response))

if __name__ == '__main__':

    # Publisherと同様に v3.1.1を利用
    client = mqtt.Client(protocol=mqtt.MQTTv311)
    client.username_pw_set(USERNAME, PASSWORD)
    client.tls_set("mqtts-cert.pem")
    client.connect(host, port=port, keepalive=60)

    client.on_connect = on_connect
    client.on_message = on_message

    # 待ち受け状態にする
    client.loop_forever()