Add rmql basic_consume-2