commit 8d6dc9bacfff16d5f48d3bbab1b2118611667497
author David Ostrovsky <david@ostrovsky.org> Sat Jul 14 08:56:47 2018 +0200
committer Luca Milanesio <luca.milanesio@gmail.com> Tue Nov 13 16:01:58 2018 -0800
tree 879ad7a676e306cbfb64596457343f5a96c73a23
parent 4ff19a12643e1eaaed907eca21dcbabee7b62560

KafkaPublisher: Remove redundant available attribute and methods

Change-Id: Ic6522c3d6c2c63f431b303312e7f07fc3dc71818

src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java b/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java
index 8c78439..27dd3e7 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaPublisher.java
@@ -27,7 +27,6 @@
 
   private final KafkaSession session;
   private final Gson gson;
-  private boolean available = true;
 
   @Inject
   public KafkaPublisher(
@@ -40,34 +39,20 @@
   public void start() {
     if (!session.isOpen()) {
       session.connect();
-      available = true;
     }
   }
 
   public void stop() {
     session.disconnect();
-    available = false;
   }
 
   @Override
   public void onEvent(Event event) {
-    if (available && session.isOpen()) {
+    if (session.isOpen()) {
       session.publish(gson.toJson(event));
     }
   }
 
-  public void enable() {
-    available = true;
-  }
-
-  public void disable() {
-    available = false;
-  }
-
-  public boolean isEnabled() {
-    return available;
-  }
-
   public String getName() {
     return "Kafka";
   }