def black_hole(queue):
 def _ignore(msg):
  print ('Ignoring msg: %r' % msg.body)
 consume_items(queue, _ignore)

def black_hole ( queue ) : def _ignore ( msg ) : print ( 'Ignoring msg: %r' % msg . body ) consume_items ( queue , _ignore )
continually empty out a queue as new items are created .