greptail

package com.open.messaging.bigbro.broker.monitor.consumer;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Consumer;

import org.springframework.core.task.TaskExecutor;

import com.open.messaging.bigbro.broker.manager.BigQueueManager;

greptail

```diagram
PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2ZXJzaW9uPSIxLjEiIHdpZHRoPSI4MzdweCIgaGVpZ2h0PSIxMDYzcHgiIHZpZXdCb3g9Ii0wLjUgLTAuNSA4MzcgMTA2MyIgY29udGVudD0iJmx0O214ZmlsZSBob3N0PSZxdW90O2VtYmVkLmRpYWdyYW1zLm5ldCZxdW90OyBtb2RpZmllZD0mcXVvdDsyMDIyLTA0LTA4VDA1OjUwOjU1LjQ2NFomcXVvdDsgYWdlbnQ9JnF1b3Q7NS4wIChXaW5kb3dzKSZxdW90OyBldGFnPSZxdW90O2RoSi1kNU56RWwwZXZhcUE0NExUJnF1b3Q7IHZlcnNpb249JnF1b3Q7MTcuNC4xJnF1b3Q7IHR5cGU9JnF1b3Q7ZW1iZWQmcXVvdDsmZ3Q7Jmx0O2RpYWdyYW0gaWQ9JnF1b3Q7QjAxS1pPS2xZYkxpQlZDMnd0Y3gmcXVvdDsgbmFtZT0mcXVvdDtQYWdlLTEmcXVvdDsmZ3Q7N1IxcmM2TEs4dGZrWXl5RzRmbFJ6Ym9uVlRkM1U1czlkVDV1SVl4S0xZSVhNSS85OVhlR2h3TGRSb3lEbUQyUTNSaUhFYUhmM2RQZGMwT242OWV2c2JOWlBVUWVDMjVVeFh1OW9YYzNLajlNbGIrSWtiZDhoRmlLblk4c1k5OHJ4dllEVC81dlZnd3F4ZWpXOTFoU201aEdVWkQ2bS9xZ0c0VWhjOVBhbUJQSDBVdDkyaUlLNnQrNmNaWU1ERHk1VGdCSC8vRzlkSldQV3JxeUgvK0wrY3RWK2MxRUtjNnNuWEp5TVpDc0hDOTZxUXpSTHpkMEdrZFJtdisxZnAyeVFFQ3ZoRXYrdWRtQnM3c2JpMW1ZdHZsQWdZbG5KOWdXejFiY1YvcFdQbXdjYlVPU

greptail

@Configuration
public class WebMvcConfig implements WebMvcConfigurer {

    @Override
    public void addResourceHandlers(ResourceHandlerRegistry registry) {

        registry.addResourceHandler("/**").addResourceLocations("classpath:/")
                .setCacheControl(CacheControl.maxAge(2, TimeUnit.DAYS).mustRevalidate().noTransform()).resourceChain(true)
                .addResolver(new PathResourceResolver() {
                    @Override

greptail

@RestController
class StudentController
{
  @Autowired
  private StudentService studentService;
  private ResponseEntity<?> createStudent(@RequestBody StudentDTO student)
  {
      studentService.save(student);
      return ResponseEntity.ok();
  }