worker.loops

The consumers highly-optimized inner loop.

Module Contents

Functions

_quick_drain(connection,timeout=0.1)
_enable_amqheartbeats(timer,connection,rate=2.0)
asynloop(obj,connection,consumer,blueprint,hub,qos,heartbeat,clock,hbrate=2.0) Non-blocking event loop.
synloop(obj,connection,consumer,blueprint,hub,qos,heartbeat,clock,hbrate=2.0,**kwargs) Fallback blocking event loop for transports that doesn’t support AIO.
_quick_drain(connection, timeout=0.1)
_enable_amqheartbeats(timer, connection, rate=2.0)
asynloop(obj, connection, consumer, blueprint, hub, qos, heartbeat, clock, hbrate=2.0)

Non-blocking event loop.

synloop(obj, connection, consumer, blueprint, hub, qos, heartbeat, clock, hbrate=2.0, **kwargs)

Fallback blocking event loop for transports that doesn’t support AIO.