Skip to content

bovine_propan.enqueuers

enqueue_broker = RabbitBroker(amqp_uri) module-attribute

Broker to be used for enqueuing items. amqp uri is determined from BOVINE_AMQP environment variable. Otherwise amqp://localhost

enqueue_to_inbox(item, actor) async

Enqueues a message for inbox processing

Source code in bovine_process/bovine_propan/enqueuers.py 
20
21
22
23
24
25
26
27
28
async def enqueue_to_inbox(item: ProcessingItem, actor):
    """Enqueues a message for inbox processing"""
    await enqueue_broker.publish(
        ProcessingMessage(
            bovine_name=actor.bovine_name, data=item.data, submitter=item.submitter
        ),
        exchange=processing,
        routing_key="inbox",
    )

enqueue_to_outbox(item, actor) async

Enqueues a message for outbox processing

Source code in bovine_process/bovine_propan/enqueuers.py 
31
32
33
34
35
36
37
38
39
async def enqueue_to_outbox(item: ProcessingItem, actor):
    """Enqueues a message for outbox processing"""
    await enqueue_broker.publish(
        ProcessingMessage(
            bovine_name=actor.bovine_name, data=item.data, submitter=item.submitter
        ),
        exchange=processing,
        routing_key="outbox",
    )