def get_batch_notification_listener(transport, targets, endpoints, allow_requeue=False, batch_size=1, batch_timeout=None):
 return oslo_messaging.get_batch_notification_listener(transport, targets, endpoints, executor='threading', allow_requeue=allow_requeue, batch_size=batch_size, batch_timeout=batch_timeout)

def get_batch_notification_listener ( transport , targets , endpoints , allow_requeue = False , batch_size = 1 , batch_timeout = None ) : return oslo_messaging . get_batch_notification_listener ( transport , targets , endpoints , executor = 'threading' , allow_requeue = allow_requeue , batch_size = batch_size , batch_timeout = batch_timeout )
return a configured oslo_messaging notification listener .