From 08410e2b804f35fee30dfc15505197c0b8bf5d11 Mon Sep 17 00:00:00 2001
From: L_DelOff <l_deloff@ldeloff.ru>
Date: Mon, 17 Jun 2024 21:39:37 +0300
Subject: [PATCH] fix

---
 .../ru/ldeloff/kafkastream/config/CircuitBreakerImpl.java   | 6 +-----
 .../ru/ldeloff/kafkastream/config/KafkaConsumerConfig.java  | 1 -
 .../java/ru/ldeloff/kafkastream/controller/Controller.java  | 2 ++
 3 files changed, 3 insertions(+), 6 deletions(-)

diff --git a/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/CircuitBreakerImpl.java b/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/CircuitBreakerImpl.java
index f6f663b..e6734a0 100644
--- a/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/CircuitBreakerImpl.java
+++ b/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/CircuitBreakerImpl.java
@@ -8,20 +8,16 @@ import org.springframework.context.annotation.Configuration;
 
 @Configuration
 public class CircuitBreakerImpl {
-    private final CircuitBreaker circuitBreaker;
     private final BindingsEndpoint bindingsEndpoint;
 
     protected CircuitBreakerImpl(BindingsEndpoint bindingsEndpoint,
                                  CircuitBreakerConfig circuitBreakerConfig) {
         this.bindingsEndpoint = bindingsEndpoint;
-        this.circuitBreaker = circuitBreakerConfig.circuitBreaker("consumerCircuitBreaker");
-
+        CircuitBreaker circuitBreaker = circuitBreakerConfig.circuitBreaker("consumerCircuitBreaker");
         circuitBreaker.getEventPublisher().onStateTransition(this::onStateChangeEvent);
     }
 
     private void onStateChangeEvent(CircuitBreakerOnStateTransitionEvent event) {
-        System.out.println("WARNING");
-
         switch (event.getStateTransition().getToState()) {
             case OPEN:
                 System.out.println("consumerAutoTestCircuitBreaker1 open");
diff --git a/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/KafkaConsumerConfig.java b/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/KafkaConsumerConfig.java
index c8f56ab..033be89 100644
--- a/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/KafkaConsumerConfig.java
+++ b/KafkaStream/src/main/java/ru/ldeloff/kafkastream/config/KafkaConsumerConfig.java
@@ -36,7 +36,6 @@ public class KafkaConsumerConfig {
             } catch (Exception e) {
                 System.out.println(e.getClass());
             }
-
         };
     }
 
diff --git a/KafkaStream/src/main/java/ru/ldeloff/kafkastream/controller/Controller.java b/KafkaStream/src/main/java/ru/ldeloff/kafkastream/controller/Controller.java
index b13001d..0bb733c 100644
--- a/KafkaStream/src/main/java/ru/ldeloff/kafkastream/controller/Controller.java
+++ b/KafkaStream/src/main/java/ru/ldeloff/kafkastream/controller/Controller.java
@@ -15,6 +15,7 @@ public class Controller {
     private final KafkaProducerConfig kafkaProducerConfig;
     private final BindingsEndpoint bindingsEndpoint;
 
+    // Ручная отправка сообщений
     @GetMapping(value = "/test1")
     public String test1() {
         kafkaProducerConfig.sendMessage1(new Model(++i));
@@ -27,6 +28,7 @@ public class Controller {
         return "test OK, i = " + i;
     }
 
+    // Переключатели состояний consumerAutoTestCircuitBreaker1-in-0
     @GetMapping(value = "/test3")
     public String test3() {
         bindingsEndpoint.changeState("consumerAutoTestCircuitBreaker1-in-0", BindingsLifecycleController.State.STOPPED);