io.radanalytics.streaming.amqp