Moustique

# Install
pip install moustique paho-mqtt

# Create client with MQTT (real-time push)
from moustique import Moustique

client = Moustique(
    ip="localhost", port="33334",
    username="demo", password="demo123",
    use_mqtt=True  # Enable MQTT for instant delivery
)

# Subscribe to messages (delivered instantly via MQTT)
def on_message(topic, message, from_name):
    print(f"📨 {topic}: {message}")

client.subscribe("/sensors/#", on_message)
client.publish("/sensors/temp", "23.5°C")

while True:
    client.tick()  # Messages arrive automatically with MQTT
    time.sleep(1)

// Install
npm install moustique

// Publish a message
import { Moustique } from 'moustique';

const client = new Moustique({
    ip: 'localhost',
    port: '33334',
    clientName: 'my-app'
});
// Or use cloud: ip: 'cloud.moustique.xyz', port: '80'

await client.publish('/sensors/temperature', '23.5');

// Subscribe to messages
await client.subscribe('/sensors/#', (topic, message, from) => {
    console.log(`Got: ${message}`);
});

setInterval(async () => {
    await client.pickup();  // Poll for messages
}, 1000);

// Install
go get github.com/moustiqueserver/moustique/clients/go/moustique

// Publish a message
package main

import "github.com/moustiqueserver/moustique/clients/go/moustique"

func main() {
    client := moustique.New("localhost", "33334", "my-app", "", "")
    // Or use cloud: New("cloud.moustique.xyz", "80", "my-app", "", "")
    client.Publish("/sensors/temperature", "23.5")

    // Subscribe to messages
    client.Subscribe("/sensors/#", func(topic, message, from string) {
        fmt.Printf("Got: %s\n", message)
    })

    for {
        client.Pickup()
        time.Sleep(time.Second)
    }
}

# Download CLI
curl -O https://moustique.xyz/downloads/moustique-cli
chmod +x moustique-cli

# Publish a message
./moustique-cli -h localhost -p 33334 -a pub \
    -t /sensors/temperature -m "23.5"

# Subscribe to messages (in another terminal)
./moustique-cli -h localhost -p 33334 -a sub \
    -t /sensors/# -c my-subscriber

# Check server version
./moustique-cli -h localhost -p 33334 -a version