It's a plugin created for Gmqtt broker, to make it act like a mqtt proxy, with messages buffering support when the destination broker is down.

1. Clone Gmqtt project

2. Edit plugin_imports.ymlfile in the root directory and add proxy plugin:

packages:
  - admin
  - prometheus
  - federation
  - auth 
  # add proxy plugin in the end of the list
  - proxy 

3. Edit cmd/gmqttd/default_config.yml file and add proxy plugin:

plugin_order:  
  - prometheus
  - admin
  - federation
  # add proxy plugin here
  - proxy

4. Go to plugin directory and clone this project:

git clone https://github.com/Oliveirakun/gmqtt-proxy-plugin.git

5. Rename the directory:

mv gmqtt-proxy-plugin proxy

5. Go back to root directory and install the plugin dependencies:

go get github.com/eclipse/paho.mqtt.golang

6. Export an environment variable with the destination broker uri:

export REMOTE_MQTT_BROKER=tcp://127.0.0.1:1884

7. Run the project:

make run

Licensed under MIT, see LICENSE