paho

6熱

1答えて

PAHO JS + ActivemqでAMQJS0008Iソケットエラーを解決しました

時々AMQJS0008I Socket closedエラーがonConnectionLostに頻繁に発生しています。私は最新のActivemqバージョンを使用しています。いつかそれはそれの間にうまく、時にはすべてのメッセージを行くので、私がでログインし、ユーザがアクセス権を持っていなかったときに私はこのメッセージを受信したエラーに

1熱

1答えて

Paho Mqtt Androidがブローカに接続すると失敗する（32103）

私のネットワークには、1883（mqtt）でリッスンしているActiveMQブローカがあります。単純なJavaアプリケーションとmqtt-client-0.4.0.jarライブラリを使用してそのブローカに接続すると、すべてが動作します。今Androidデバイスでそのブローカーに接続します。残念ながら、私は成功した接続を得るためにそれを管理することはできません。 03-23 11:08:15.67

0熱

1答えて

他のクライアントがサーバに接続したときにMqttクライアントが切断される

MQTTメッセージングシステムを初めて使いましたが、AOSP kk-4.4.2を実行しているスナップドラゴンボードにpaho Androidサービスを実装できました。起動時にサービスが開始され、ポート1883でHiveMQのパブリックブローカに接続されます。私のカスタムAOSPを実行しているAndroidデバイスをサーバーに接続してから、電話で実行されているアンドロイドアプリケーションから別のク

1熱

2答えて

ユニークな着信メッセージをリストに追加するにはどうすればよいですか？

私はRFIDリーダを使用してメッセージを受信しています。私はそれらをemptylist = []に追加することによって重複したメッセージを避けようとしています。リストにそれらが存在する場合、メッセージを追加しません。以下は私のコードです： import paho.mqtt.client as mqtt def on_connect(client, userdata, flags, rc):

0熱

1答えて

mosquittoブローカーは複数のメッセージを保持します

私はEC2のUbuntuで実行中のmosquittoブローカを持っています。また、私はのQoS = 2とで、私はこのブローカーに公開しています/etc/mosquitto/mosquitto.conf の変化max_queued_messages 1000とmax_inflight_messages 10をしたがを有効に保持しています。出版のために私はmosquitto_pub -t 1 -m "

1熱

1答えて

MQTTクライアントのロードバランシング

元々、私のセットアップでは、購読メッセージを消費するスレッドプールがあります。 MQTTのロードバランスは可能ですか？これらは、https://groups.google.com/forum/#!topic/mqtt/kUgBFgBmcGkが見つかりましたが、その死んだようです。

2熱

2答えて

Paho Python MQTTクライアントは正常に接続されますが、on_connectコールバックは呼び出されません。

3秒ごとにサンプルメッセージを発行するRaspberry Piの簡単なスクリプトがあります。私は、コールバックon_connect、on_publish、on_disconnectを宣言しました。このクライアントは正常に接続されますが、on_connectは呼び出されず、publishされ、on_publishが呼び出され、disconnectsおよびon_disconnectが呼び出されます。

1熱

1答えて

MQTTクライアントをアンドロイドで再接続

私はアンドロイドアプリでmqtt pahoライブラリを使用しています。 mqttクライアントがネットワークの問題により接続を失うまで、正常に動作します。クライアントを手動で接続する必要がありますか、自動的に接続するためのメカニズムがあります。