heroku cloudMQTT<->raspberryPiの接続

Question

herokuのcloudMQTTとraspberryPiをmqttで接続し、以下のpythonプログラムでメッセージのやり取りを行おうとしていますが、動作しません。（しているのか分かりません）

 1 import paho.mqtt.client as mqtt
 2
 3 def on_connect(client,userdata, rc):
 4     #print("Connected with result code "+str(rc))
 5     print("Connected to cloudMQTT")
 6     client.subscribe("isyjp/msg1st")
 7
 8 def on_message(client, userdata, msg):
 9     print(msg.topic+" "+str(msg.payload))
10
11 client = mqtt.Client()
12 client.on_connect = on_connect
13 client.on_message = on_message
14
15 client.tls_set("/etc/ssl/certs/ca-certificates.crt")
16
17 client.username_pw_set('cloudMQTTで与えられたuser名','cloudMQTTで与えられたパスワード')
18 client.connect('cloudMQTTのサーバ名',SSLポート)
19
20 client.loop_forever()

cloudMQTTの"CONNECTIONS"を見ると、
MQTT
No connections
MQTT over SSL
xx.xx.xx.xxx:3xxx
Websockets
No connections
となっています。
ネット上の参考とさせて頂いている記述(http://independence-sys.net/main/?p=4058)によると、上記のプログラムを実行すると、"Connected with result code 0"となるはずなのですが、何も表示されません。また、Websocket UIからisyjp/msg1stにメッセージを送ると、raspberryPi上でメッセージが見えるはずなのですが、何も表示されません。
cloudMQTTの設定->Paho-mqttのインストール->上記プログラムの実行以外に、何か設定等が必要でしょうか。
もしくは上記のプログラムに不備があるでしょうか。初めてmqtt、herokuを利用するのでご指導下さい。

Answer 1

def on_connect(client,userdata, rc):

を

def on_connect(client,userdata, flags, rc):

に変更したところ動作しましたので報告します。

Comments

[hekatonkeiru]

ありがとうございますm(__)m
こちらも似たような悩みでしたが無事解決いたしました。