nti.webhooks.delivery_manager

Default implementation of the delivery manager.

interface nti.webhooks.delivery_manager.IExecutorService

Internal interface for testing. See nti.webhooks.testing.SequentialExecutorService for the alternate implementation.

submit(func)

Submit a job to run. Execution may or may not commence in the background. Tracks tasks that have been submitted and not yet finished.

waitForPendingExecutions(timeout=None)

Wait for all tasks that have been submitted but not yet finished to finish. submit, wait for them all to finish. If any one of them raises an exception, this method should raise an exception.

shutdown()

Stop accepting new tasks.

class nti.webhooks.delivery_manager.DefaultDeliveryManager(name)

Bases: zope.container.contained.Contained