Monstermq Broker Config

# Network listener ports (0 = disabled)
Port:
  TCP: 1883       # Plain MQTT
  TCPS: 8883      # MQTT over TLS
  WS: 1884        # WebSocket
  WSS: 8884       # Secure WebSocket
  HTTP: 4000      # GraphQL API + Dashboard + REST API
  NATS: 4222      # Native NATS listener

# Server Ports (Protocol & Service Servers)
MCP:
  Enabled: true
  Port: 3000
Prometheus:
  Enabled: false
  Port: 3001
I3x:
  Enabled: false
  Port: 3002
RedisServer:
  Enabled: false
  Port: 6379
KafkaServer:
  Enabled: false
  Port: 9092

# Storage backend defaults
DefaultStoreType: POSTGRES | MONGODB | SQLITE # Global default for store types if not overridden
SessionStoreType: POSTGRES | MONGODB | SQLITE | MEMORY
RetainedStoreType: MEMORY | HAZELCAST | POSTGRES | CRATEDB | MONGODB | SQLITE
LastValueStoreType: MEMORY | HAZELCAST | POSTGRES | CRATEDB
QueueStoreType: POSTGRES | MONGODB | SQLITE    # Defaults to DefaultStoreType or persistent SessionStoreType. V2 single-table design.

# Zenoh Broker Federation (Optional)
Zenoh:
  Enabled: false
  Mode: peer | client
  Connect: []
  RemotePrefix: "monstermq/mqtt"
  LocalPrefix: ""

# High-load performance batching
BulkProcessing:
  Enabled: false
  TimeoutMS: 50
  BulkSize: 1000
  WorkerThreads: 4

BulkMessaging:
  Enabled: true
  TimeoutMS: 100
  BulkSize: 1000

# Database connection pools
Postgres:
  Url: "jdbc:postgresql://localhost:5432/monster"
  User: "system"
  Password: "manager"
  Schema: "public"            # Optional PostgreSQL schema name

CrateDB:
  Url: "jdbc:postgresql://localhost:5433/monster"
  User: "crate"
  Password: ""

MongoDB:
  ConnectionString: "mongodb://system:manager@localhost:27017"
  DatabaseName: "monster"

SQLite:
  Path: "sqlite"
  EnableWAL: true

# Message Archiving Groups
ArchiveGroups:
  - Name: "Default"           # Required for MCP Server & general topics
    TopicFilter: ["#"]
    StoreType: Postgres | CrateDB | MongoDB | Kafka
    RetainedStoreType: Postgres | CrateDB
    LastValueStoreType: Postgres | CrateDB

# Top-level Feature Flags (Gating Verticles & GraphQL Mutations)
Features:
  OpcUa: true                 # OPC UA Client bridge
  OpcUaServer: true           # Embedded OPC UA Server
  MqttClient: true            # Remote MQTT broker bridge
  Kafka: true                 # Kafka client bridge
  KafkaServer: true           # Kafka-compatible server
  Nats: true                  # NATS bridge
  Redis: true                 # Redis Pub/Sub & KV bridge
  RedisServer: true           # Redis-compatible protocol server
  Telegram: true              # Telegram bot bridge
  WinCCOa: true               # WinCC OA connector
  WinCCUa: true               # WinCC Unified connector
  Plc4x: true                 # PLC4X connector (S7, Modbus, AB)
  Neo4j: true                 # Neo4j graph database logger
  JdbcLogger: true            # JDBC SQL logger
  InfluxDBLogger: true        # InfluxDB logger device
  TimeBaseLogger: true        # TimeBase logger device
  SparkplugB: true            # SparkplugB decoder
  FlowEngine: true            # Visual flow engine
  Agents: true                # AI agent framework
  GenAi: true                 # GenAI provider management
  Mcp: true                   # MCP server management
  SchemaPolicy: true          # Topic schema policy management
  TopicNamespace: true        # Topic namespace management
  DeviceImportExport: true    # Device configuration import/export
  Zenoh: true                 # Zenoh broker federation transport
  I3xClient: true             # i3X client bridge

# User Management & Auth
Auth:
  UserStoreType: Postgres | MONGODB | SQLITE
  JwtSecret: "your-secret-key"
  TokenExpiry: 3600            # seconds
  PasswordAlgorithm: bcrypt

# GenAI Providers
GenAI:
  Enabled: true
  Providers:
    Gemini:
      ApiKey: "${GENAI_GEMINI_API_KEY}"
    Claude:
      ApiKey: "${GENAI_CLAUDE_API_KEY}"
    OpenAI:
      ApiKey: "${GENAI_OPENAI_API_KEY}"
    Ollama:
      BaseUrl: "http://localhost:11434"

cd broker
./run.sh [options]

# Run options:
-cluster              Enable Hazelcast clustering mode
-log LEVEL            Set logging verbosity: INFO | FINE | FINER | FINEST | ALL
-config FILE          Path to custom YAML config file (default: config.yaml)
-build                Rebuild Vite dashboard + package JAR before running

cd docker
./build.sh

docker run -d \
  -p 1883:1883 \
  -p 4222:4222 \
  -p 4000:4000 \
  -v ./config.yaml:/app/config.yaml \
  -v ./log:/app/log \
  rocworks/monstermq:latest

services:
  monstermq:
    image: rocworks/monstermq:latest
    ports:
      - "1883:1883"
      - "4000:4000"
      - "4222:4222"
    volumes:
      - ./config.yaml:/app/config.yaml
    depends_on:
      - postgres

  postgres:
    image: postgres:16
    environment:
      POSTGRES_DB: monster
      POSTGRES_USER: system
      POSTGRES_PASSWORD: manager
    ports:
      - "5432:5432"
    volumes:
      - pgdata:/var/lib/postgresql/data

volumes:
  pgdata: