Merge pull request #16 from iot-dsa-v2/develop

1.1.2

Author: d-shapiro

dslink.json

@@ -1,6 +1,6 @@
 {
   "name": "dslink-java-v2-restadapter",
-  "version": "1.1.1",
+  "version": "1.1.2",
   "description": "Java DSA to REST adpater DSLink",
   "main": "bin/dslink-java-v2-restadapter",
   "configs": {

src/main/java/org/iot/dsa/dslink/restadapter/SubscriptionRule.java

@@ -20,7 +20,7 @@
 import org.iot.dsa.util.DSException;
 import okhttp3.Response;
 
-public class SubscriptionRule extends DSLogger implements OutboundSubscribeHandler {
+public class SubscriptionRule extends DSLogger implements OutboundSubscribeHandler, UpdateSender {
 
     private AbstractRuleNode node;
     private OutboundStream stream;

src/main/java/org/iot/dsa/dslink/restadapter/UpdateSender.java

@@ -0,0 +1,11 @@
+package org.iot.dsa.dslink.restadapter;
+
+import java.util.Queue;
+
+public interface UpdateSender {
+    
+    public int getMaxBatchSize();
+    
+    public Queue<SubUpdate> sendBatchUpdate(Queue<SubUpdate> updates);
+
+}

src/main/java/org/iot/dsa/dslink/restadapter/Util.java

@@ -104,7 +104,7 @@ public static void storeInBuffer(String subId, SubUpdate update) {
 //        return true;
 //    }
 
-    public static boolean processBuffer(String subId, SubscriptionRule subRule) {
+    public static boolean processBuffer(String subId, UpdateSender subRule) {
         if (buffer == null) {
             return true;
         }