refactor: 优化PersistenceBuffer逻辑

jetlinks-components/common-component/src/main/java/org/jetlinks/community/buffer/BufferProperties.java

@@ -22,4 +22,8 @@ public class BufferProperties {
 
     //最大重试次数,超过此次数的数据将会放入死队列.
     private long maxRetryTimes = 64;
+
+    public boolean isExceededRetryCount(int count) {
+        return maxRetryTimes > 0 && count >= maxRetryTimes;
+    }
 }

jetlinks-components/common-component/src/main/java/org/jetlinks/community/buffer/Buffered.java

@@ -0,0 +1,31 @@
+package org.jetlinks.community.buffer;
+
+/**
+ * 已缓冲的数据
+ *
+ * @param <T> 数据类型
+ * @author zhouhao
+ * @since 2.2
+ */
+public interface Buffered<T> {
+
+    /**
+     * @return 数据
+     */
+    T getData();
+
+    /**
+     * @return 当前重试次数
+     */
+    int getRetryTimes();
+
+    /**
+     * 标记是否重试此数据
+     */
+    void retry(boolean retry);
+
+    /**
+     * 标记此数据为死信
+     */
+    void dead();
+}