ConsumerBuilder extends AbstractReferenceBuilder<ConsumerConfig, ConsumerBuilder> { public ConsumerBuilder coreThreads(Integer coreThreads) { this.corethreads = coreThreads; return getThis(); }  ConsumerBuilder isDefault(Boolean isDefault); ConsumerBuilder client(String client); ConsumerBuilder threadPool(String threadPool); ConsumerBuilder coreThreads(Integer coreThreads); ConsumerBuilder threads(Integer threads); ConsumerBuilder queues(Integer queues); ConsumerBuilder shareConnections(Integer shareConnections); ConsumerConfig build();  }
@Test void coreThreads() { ConsumerBuilder builder = new ConsumerBuilder(); builder.coreThreads(10); Assertions.assertEquals(10, builder.build().getCorethreads()); }