m (→Participant Example Code) |
m |
||
| Line 28: | Line 28: | ||
from RuoteAMQP.workitem import Workitem | from RuoteAMQP.workitem import Workitem | ||
from RuoteAMQP.participant import Participant | from RuoteAMQP.participant import Participant | ||
| + | </pre> | ||
| + | |||
| + | ==== Class definition ==== | ||
| + | |||
| + | <pre> | ||
| + | class NotifierParticipant(Participant): | ||
| + | def collect_and_send(self, wi): | ||
</pre> | </pre> | ||
Contents |
BOSS is a workflow orchestrator, a system that can be configured to automate your workflow requirements; it interacts with the OBS and with people and systems around it to apply your workflow steps. For more BOSS related general information, see Infrastructure/BOSS.
BOSS Participant the actual actor in BOSS architecture. Participant wraps other systems and services related to software development, quality assurance and integration, allowing BOSS to interact with different parties in automated way.
BOSS Participant action explained in three simple steps:
BOSS participant is written in Python language (other bindings will be available later).
???
from RuoteAMQP.workitem import Workitem from RuoteAMQP.participant import Participant
class NotifierParticipant(Participant):
def collect_and_send(self, wi):
if __name__ == "__main__":
print "Notifier participant running"
p = NotifierParticipant(ruote_queue="notifier", amqp_vhost="ruote-test")
p.register("notifier", {'queue':'notifier'})
p.run()
See following participants for example implementation: [notifier_participant.py] [build_ks_participant.py]