data source - use langohr for RMQ connectivity