Showing
2 changed files
with
2 additions
and
2 deletions
| @@ -70,7 +70,7 @@ public abstract class AbstractSimpleSqlTimeseriesDao<T extends AbstractTsKvEntit | @@ -70,7 +70,7 @@ public abstract class AbstractSimpleSqlTimeseriesDao<T extends AbstractTsKvEntit | ||
| 70 | 70 | ||
| 71 | @PreDestroy | 71 | @PreDestroy |
| 72 | protected void destroy() { | 72 | protected void destroy() { |
| 73 | - super.init(); | 73 | + super.destroy(); |
| 74 | if (tsQueue != null) { | 74 | if (tsQueue != null) { |
| 75 | tsQueue.destroy(); | 75 | tsQueue.destroy(); |
| 76 | } | 76 | } |
| @@ -107,7 +107,7 @@ public class TimescaleTimeseriesDao extends AbstractSqlTimeseriesDao implements | @@ -107,7 +107,7 @@ public class TimescaleTimeseriesDao extends AbstractSqlTimeseriesDao implements | ||
| 107 | 107 | ||
| 108 | @PreDestroy | 108 | @PreDestroy |
| 109 | protected void destroy() { | 109 | protected void destroy() { |
| 110 | - super.init(); | 110 | + super.destroy(); |
| 111 | if (queue != null) { | 111 | if (queue != null) { |
| 112 | queue.destroy(); | 112 | queue.destroy(); |
| 113 | } | 113 | } |