Remove init method.

yanrongzhen · yanrongzhen · commit f67126cc77dd · 2023-10-24T11:47:31.000+08:00
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcServer.java
@@ -119,7 +119,6 @@ public void init() throws Exception {
         consumerManager.init();
 
         grpcRetryer = new GrpcRetryer(this);
-        grpcRetryer.init();
 
         int serverPort = eventMeshGrpcConfiguration.getGrpcServerPort();
 
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHTTPServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHTTPServer.java
@@ -124,7 +124,6 @@ public void init() throws Exception {
                 pluginType -> metricsRegistries.add(MetricsPluginFactory.getMetricsRegistry(pluginType))));
 
         httpRetryer = new HttpRetryer(this);
-        httpRetryer.init();
 
         super.setMetrics(new HTTPMetricsServer(this, metricsRegistries));
         subscriptionManager = new SubscriptionManager(eventMeshHttpConfiguration.isEventMeshServerMetaStorageEnable(), metaStorage);
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshTCPServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshTCPServer.java
@@ -103,7 +103,6 @@ public void init() throws Exception {
                 pluginType -> metricsRegistries.add(MetricsPluginFactory.getMetricsRegistry(pluginType))));
 
         tcpRetryer = new TcpRetryer(this);
-        tcpRetryer.init();
 
         clientSessionGroupMapping = new ClientSessionGroupMapping(this);
         clientSessionGroupMapping.init();
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java
@@ -43,11 +43,6 @@ public void newTimeout(TimerTask timerTask, long delay, TimeUnit timeUnit) {
         timer.newTimeout(timerTask, delay, timeUnit);
     }
 
-    @Override
-    public void init() {
-
-    }
-
     @Override
     public void start() {
         if (timer == null) {
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/retry/Retryer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/retry/Retryer.java
@@ -26,8 +26,6 @@
  */
 public interface Retryer {
 
-    void init();
-
     void start();
 
     void shutdown();
