Parent: [72d7c3] (diff)

Child: [3abc56] (diff)

Download this file

amqp.py    18 lines (13 with data), 435 Bytes

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
import logging
from lamson.routing import route, route_like, stateless
from config.settings import relay
from lamson import view, queue
@route("forge-list@(host)")
#@route("(post_name)@osb\\.(host)")
@stateless
def POSTING(message, post_name=None, host=None):
relay.deliver(message)
# drop the message off into the 'posts' queue for later
index_q = queue.Queue("run/posts")
index_q.push(message)
return POSTING