refactored to use the new Duct[A, B] type instead of Flow[A] => Flow[B] transformations
added logging
two different outbound queues