Snakemake Logger Plugin for STOMP

Send Snakemake workflow events monitoring to a STOMP message broker (ActiveMQ, RabbitMQ, etc.) in real-time.

Installation

pip install snakemake-logger-plugin-stomp

Quick Start

snakemake --logger stomp \
  --logger-stomp-host localhost \
  --logger-stomp-port 61613 \
  --logger-stomp-user admin \
  --logger-stomp-password admin \
  --logger-stomp-queue /queue/snakemake.events

Or use a profile:

# profiles/stomp/config.yaml
logger:
  stomp:
    host: "activemq.example.com"
    port: 61613
    user: "${STOMP_USER}"
    password: "${STOMP_PASSWORD}"
    queue: "/topic/snakemake.prod"

Features

• JSON event streaming to message brokers
• SSL/TLS support
• Configurable formatters (default + JLab SWF schema)
• Event filtering (include/exclude)
• Heartbeat management
• Environment variable support for secrets