This document describes the current stable version of Kombu (4.2). For development docs, go here.

Event Loop - kombu.asynchronous

Event loop.

class kombu.asynchronous.Hub(timer=None)

Event loop object.

Parameters:timer (kombu.asynchronous.Timer) – Specify custom timer instance.

ERR = 24

READ = 1

WRITE = 4

add(fd, callback, flags, args=(), consolidate=False)

add_reader(fds, callback, *args)

add_writer(fds, callback, *args)

call_at(when, callback, *args)

call_later(delay, callback, *args)

call_repeatedly(delay, callback, *args)

call_soon(callback, *args)

close(*args)

create_loop(generator=<type 'generator'>, sleep=<built-in function sleep>, min=<built-in function min>, next=<built-in function next>, Empty=<class 'Queue.Empty'>, StopIteration=<type 'exceptions.StopIteration'>, KeyError=<type 'exceptions.KeyError'>, READ=1, WRITE=4, ERR=24)

fire_timers(min_delay=1, max_delay=10, max_timers=10, propagate=())

loop

on_callback_error(callback, exc)

on_close = None

remove(fd)

remove_reader(fd)

remove_writer(fd)

repr_active()

repr_events(events)

reset()

run_forever()

run_once()

scheduler

stop()

kombu.asynchronous.get_event_loop()

Get current event loop object.

kombu.asynchronous.set_event_loop(loop)

Set the current event loop object.