List of all items

Structs

• component::poll::Capacity
• component::poll::Job

Enums

• Error
• component::aggregate::AggregationStatus
• rmq_primitive::AckType
• rmq_primitive::Responsibility

Macros

• add_to_jobs
• aggregate
• fan_out
• maybe_send_to_next
• user_handler

Functions

• component::poll::new_job
• component::poll::poll_forever
• rmq::consume_forever
• rmq_init::init_exchanges_and_queues
• rmq_init::init_work_queue
• rmq_primitive::create_channel
• rmq_primitive::name_of_retry_queue
• rmq_primitive::publish
• rmq_primitive::unreliable_ack_or_reject

Typedefs

• Result
• component::poll::Jobs