add Number of messages WS queue shuold hold, default 100

zhouaini528 · Jan 26, 2021 · d4e692c · d4e692c
1 parent 833887f
commit d4e692c
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -196,6 +196,9 @@ $bitmex->config([
     //Heartbeat time,default 30 seconds
     //'ping_time'=>30,
 
+    //Number of messages WS queue shuold hold, default 100
+    //'queue_count'=>100,
+
     //baseurl host
     //'baseurl'=>'ws://www.bitmex.com/realtime',//default
     //'baseurl'=>'ws://testnet.bitmex.com/realtime',//test
@@ -232,6 +235,12 @@ $bitmex->config([
     //Heartbeat time,default 30 seconds
     //'ping_time'=>30,
 
+    //Number of messages WS queue shuold hold, default 100
+    //'queue_count'=>100,
+
+    //私有数据队列默认保存100条
+    //'queue_count'=>100,
+
     //baseurl host
     //'baseurl'=>'ws://www.bitmex.com/realtime',//default
     //'baseurl'=>'ws://testnet.bitmex.com/realtime',//test

diff --git a/README_CN.md b/README_CN.md
@@ -196,6 +196,9 @@ $bitmex->config([
     //心跳时间默认 30 seconds
     //'ping_time'=>30,
 
+    //私有数据队列默认保存100条
+    //'queue_count'=>100,
+
     //baseurl host 地址设置
     //'baseurl'=>'ws://www.bitmex.com/realtime',//默认地址
     //'baseurl'=>'ws://testnet.bitmex.com/realtime',//test

diff --git a/src/Api/WebSocket/SocketGlobal.php b/src/Api/WebSocket/SocketGlobal.php
@@ -84,7 +84,7 @@ protected function getQueue($key){
      */
     protected function saveQueue($key,$value){
         //最大存储数据量，超过后保留一条最新的数据，其余数据全部删除。
-        $max=100;
+        $max= isset($this->config['queue_count']) ? $this->config['queue_count'] : 100;
 
         if(!isset($this->client->$key)) $this->add($key,[$value]);
         else {