class CarreraConsumer extends BaseCarreraConsumerPool {

    public synchronized void startConsume(MessageProcessor processor, int concurrency) {
        baseStartConsume(processor, concurrency, Collections.EMPTY_MAP);
    }

    public  CarreraConsumer(CarreraConfig config);

}