AMQP subscriber/publisher components for RFlow