Metadata-Version: 2.4
Name: snakemake-logger-plugin-stomp
Version: 0.1.0
Summary: Snakemake logger plugin for streaming events to STOMP message brokers
Project-URL: Homepage, https://github.com/JeffersonLab/snakemake-logger-plugin-stomp
Project-URL: Repository, https://github.com/JeffersonLab/snakemake-logger-plugin-stomp
Project-URL: Documentation, https://snakemake.github.io/snakemake-plugin-catalog/plugins/logger/stomp.html
Project-URL: Bug Tracker, https://github.com/JeffersonLab/snakemake-logger-plugin-stomp/issues
Author-email: Anil Panta <anilpanta2@gmail.org>
License: MIT
License-File: LICENSE
Keywords: activemq,logger,messaging,plugin,rabbitmq,snakemake,stomp
Classifier: Development Status :: 4 - Beta
Classifier: Intended Audience :: Developers
Classifier: Intended Audience :: Science/Research
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Topic :: System :: Logging
Classifier: Topic :: System :: Monitoring
Requires-Python: <4.0,>=3.11
Requires-Dist: snakemake-interface-common<2,>=1.22.0
Requires-Dist: snakemake-interface-logger-plugins<3,>=2.0.0
Requires-Dist: stomp-py>=8.2.0
Description-Content-Type: text/markdown

# Snakemake Logger Plugin for STOMP

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

## Installation

```bash
pip install snakemake-logger-plugin-stomp
```

## Quick Start
```bash
snakemake --logger-plugin stomp \
  --stomp-host localhost \
  --stomp-port 61613 \
  --stomp-user admin \
  --stomp-password admin
```

Or use a profile:
```yaml
# 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