diff --git a/xchange-okcoin/src/main/java/info/bitrich/xchangestream/okcoin/OkCoinStreamingService.java b/xchange-okcoin/src/main/java/info/bitrich/xchangestream/okcoin/OkCoinStreamingService.java
index <HASH>..<HASH> 100644
--- a/xchange-okcoin/src/main/java/info/bitrich/xchangestream/okcoin/OkCoinStreamingService.java
+++ b/xchange-okcoin/src/main/java/info/bitrich/xchangestream/okcoin/OkCoinStreamingService.java
@@ -38,7 +38,9 @@ public class OkCoinStreamingService extends JsonNettyStreamingService {
                 pingPongTimer.schedule(new TimerTask() {
                     @Override
                     public void run() {
-                        OkCoinStreamingService.this.sendMessage("{\"event\":\"ping\"}");
+                        if (OkCoinStreamingService.this.isSocketOpen()) {
+                            OkCoinStreamingService.this.sendMessage("{\"event\":\"ping\"}");
+                        }
                     }
                 }, 15 * 1000, 15 * 1000);
                 completable.onComplete();
do not send pingpong when disconnected