SpringBoot單元測試時不運行kafka、rabbitmq等隊列消費者

SpringBoot單元測試時屏蔽kafka、rabbitmq等隊列消費者

# 在單元測試的class上加上該注解即可
	@TypeExcludeFilters({ListenerExcludeFilter.class})
    public class AppTest {
        # .......
    }

ListenerExcludeFilter.class代碼

public class ListenerExcludeFilter extends TypeExcludeFilter {
  # rabbitmq同理
  private static final String KAFKA_LISTENER = "org.springframework.kafka.annotation.KafkaListener";
  private static final String KAFKA_HANDLER = "org.springframework.kafka.annotation.KafkaHandler";

  @Override
  public boolean match(MetadataReader metadataReader,
    MetadataReaderFactory metadataReaderFactory) {
    AnnotationMetadata annotationMetadata =
      metadataReader.getAnnotationMetadata();
    return annotationMetadata.hasAnnotatedMethods(KAFKA_LISTENER)
      || annotationMetadata.hasAnnotatedMethods(KAFKA_HANDLER);
  }

  @Override
  public boolean equals(Object o) {
    return o != null && getClass() == o.getClass();
  }

  @Override
  public int hashCode() {
    return 1;
  }
}