STOMP meets bottle.py
pip install shattered
shattered run
will run a Shattered app, using one of the following (in order):
- The
--app
flag. - The
SHATTERED_APP
environment variable. app.py
as the application module name.
Use shattered config
to see the current configuration (same app resolution as run
command).
app.py
import logging
from shattered import Shattered
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)
app = Shattered(host="rabbitmq")
@app.subscribe("/queue/echo")
def echo(headers, body, conn):
logger.info("%s %s", headers, body)
@app.subscribe("/queue/echo")
def echo_fancy(headers, body, conn):
logger.info("✨✨✨%s %s✨✨✨", headers, body)
app.run()
Start up RabbitMQ using docker-compose up
In another shell, run docker-compose run shattered python examples/echo/echo.py
In another shell, run docker-compose run shattered python examples/echo/send.py