Stack Overflow
Stack Overflow

Questions tagged [emq]

EMQ (EMQX) is a distributed, massively scalable, highly extensible MQTT message broker written in Erlang/OTP.

Official Resources

69 questions
9
votes
0 answers

Erlang mqtt keeps crashing

My emqttd server crashes often and I can't figure out why. Here's a snippet of the error.log file: 2018-04-19 10:53:05.215 [error] <0.6456.0> gen_server <0.6456.0> terminated with reason: no match of right hand value {pubrel,76,{1524,127985,200713}}…
David ten Hove
  • 2,748
  • 18
  • 33
6
votes
2 answers

How can i connect a Java mqtt client with username and password to an emqttd(EMQ) broker?

I am able to subscribe to the mosquitto broker with this Java code, without username and password. Now, i would like to subscribe to an emqttd broker which requires some dummy username and password. How can i do this?.…
R.Alamsha
  • 85
  • 1
  • 6
3
votes
1 answer

Emq mqtt clustering : Client Session management

I've gone through the documentation for emq clustering but i couldn't find a clear explanation for how session management is done. I understand topics table is shared among clustered nodes but client connection information is not? What happens if a…
brainfreak
  • 137
  • 1
  • 13
2
votes
1 answer

Is having a channel per user a good idea in MQTT?

I was developing a chat system for a company, and played around a lot of tools available to do so. One of my most interesting journey was through Pheonix framework (Elixer Language! phew) I ended up using an MQTT based server to manage chat. I had…
karx
  • 557
  • 2
  • 6
  • 16
2
votes
1 answer

Unexpected HTTP Request: POST /mqtt/auth

I am new to emqtt. I am trying to use emq_auth_http but it is not working. I have these 3 requests to console some data and send data back with status 200. app.post('/mqtt/auth', function(req, res) { console.log('This is body ',…
Unknown
  • 373
  • 1
  • 4
  • 15
2
votes
2 answers

Dockerfile RUN shell-script not running during docker build

I try to build a custom image for the EMQ MQTT server. But the script update_config.sh is not executed by during docker copmose up. Dockerfile: FROM emqttd-docker-v2.3.5 # change configuration file ADD update_config.sh…
Martin
  • 818
  • 9
  • 20
2
votes
2 answers

Is there any way to give TTL for messages in MQTT Broker

In the MQTT specification there are connect flags which governs the retention and state on server and client. The clean session specification suggests: 3.1.2.4 Clean Session Position: bit 1 of the Connect Flags byte. This bit specifies the…
enator
  • 2,431
  • 2
  • 28
  • 46
2
votes
1 answer

Emoji Encoding and Decoding erlang from list to binary

I want this string to be parsed for VOIP Notification for iOS to binary string: "{\"data\":{\"text\":\"❤️\"}}" I expected the data printed on the Erlang shell to be: <<"{\"data\":{\"text\":\"❤️\"}}">> But when printed it…
Sohail Germanwala
  • 21
  • 2
1
vote
1 answer

How to subscribe to all topics/messages using NodeJS mqtt, emqx

I am writing an MQTT subscriber in NodeJS using the mqtt package. The goal of this subscriber is to receive all messages coming to any/all topics but looks like the subscription to # (subscribe to all topics) does not seem to work. But when I…
Soumitri Pattnaik
  • 3,246
  • 4
  • 24
  • 42
1
vote
2 answers

emqx MQTT broker doesn’t persist session after restart

I'm using emqx broker and I want to persist session on disk so that I can recover sessions if the broker reboot for any reasons. What I do: start the emqx broker with a docker-compose: emqx1: image: emqx/emqx:v4.0.0 environment: -…
cylon86
  • 550
  • 4
  • 20
1
vote
1 answer

"tlsv1 alert unknown ca" error when using new SSL certificates

I am configuring emqtt MQTT Broker with SSL/TLS certificates from Digicert. I had done the SSL configuration for the same broker some years back and it was fine. But when I configured the new broker installation with new certificates, I am getting…
Kiran G
  • 67
  • 1
  • 2
  • 8
1
vote
0 answers

Can we use Elixir plugins with EMQ X Broker?

EMQ X has the provision to build with Elixir based plugins as per https://github.com/emqx/emqx-rel#build-with-elixir-plugins. But, it's not compiling and throwing the following error ➜ make ln -snf _build/emqx/lib ./_checkouts EMQX_DESC="EMQ X…
sokc
  • 51
  • 2
1
vote
1 answer

nginx to load balance on MQTTS

I found some documentation and successfully implemented a Load Balancing for MQTT with nginx. stream { upstream broker { server 10.1.0.3:1883 fail_timeout=1s max_fails=1; server 10.1.0.5:1883 fail_timeout=1s max_fails=1; …
TDawg
  • 833
  • 2
  • 8
  • 24
1
vote
3 answers

paho-mqtt won't give me the queued messages

Using paho-mqtt and trying to have it receive queued messages. The broker I'm using is emqx 4.2.2 and this is my script: from paho.mqtt.client import Client, MQTTv5 def on_connect(mqttc, obj, flags, rc, other): print(" Session present: " +…
Liviu
  • 1,023
  • 2
  • 12
  • 33
1
vote
2 answers

Not able to connect to emqx mqtt broker over wss from https client

I have a emqx mqtt broker running on EC2 and the ssl and wss configuration looks like this - listener.ssl.external = 8883 listener.ssl.external.keyfile = /etc/emqx/certs/key.pem listener.ssl.external.certfile =…
Bharat Chhabra
  • 1,686
  • 2
  • 14
  • 20
1
2 3 4 5