vertx cleans timers, http clients and bus handlers created in the ver…

…ticle automatically
hawkular · Jun 26, 2015 · 3d02cea · 3d02cea
1 parent c64bf9f
commit 3d02cea
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/.../ptranslator/src/main/java/org/hawkular/metrics/clients/ptrans/backend/MetricsSender.java b/.../ptranslator/src/main/java/org/hawkular/metrics/clients/ptrans/backend/MetricsSender.java
@@ -60,7 +60,6 @@ public class MetricsSender extends AbstractVerticle {
     private final List<SingleMetric> queue;
 
     private HttpClient httpClient;
-    private long timerId;
     private long sendTime;
 
     public MetricsSender(Configuration configuration) {
@@ -91,7 +90,7 @@ public void start(Future<Void> startFuture) throws Exception {
                                                                      .setKeepAlive(true)
                                                                      .setTryUseCompression(true);
         httpClient = vertx.createHttpClient(httpClientOptions);
-        timerId = vertx.setPeriodic(MILLISECONDS.convert(batchDelay, SECONDS), this::flushIfIdle);
+        vertx.setPeriodic(MILLISECONDS.convert(batchDelay, SECONDS), this::flushIfIdle);
         sendTime = System.nanoTime();
         vertx.eventBus().registerDefaultCodec(SingleMetric.class, new SingleMetricCodec());
         vertx.eventBus().localConsumer(METRIC_ADDRESS, this::handleMetric)
@@ -148,12 +147,6 @@ private void flushIfIdle(Long timerId) {
         }
     }
 
-    @Override
-    public void stop() throws Exception {
-        vertx.cancelTimer(timerId);
-        httpClient.close();
-    }
-
     public static class SingleMetricCodec implements MessageCodec<SingleMetric, SingleMetric> {
         @Override
         public void encodeToWire(Buffer buffer, SingleMetric singleMetric) {