start using Failure class for errors
adding some runnable code to main
use consumer-specific active queues