gistfile1.txt

https://github.com/jortel/gofer/blob/master/src/gofer/messaging/adapter/model.py#L711

Petty much like the Reader.
Need to configuration and plugin.refresh() done first.
Example assumes queue named pulp.qneeded and the message should probably be the plugin.cfg.messaging.uuid

---

from gofer.messaging import NotFound, Sender

try:
    with Sender(url) as sender:
        sender.send('pulp.qneeded', 'pulp.agent.12345')
except NotFound:
    pass