diff --git a/bbgo/exchange/binance/stream.go b/bbgo/exchange/binance/stream.go
index 0fa76d37e..4aae85ac2 100644
--- a/bbgo/exchange/binance/stream.go
+++ b/bbgo/exchange/binance/stream.go
@@ -158,6 +158,7 @@ func (s *PrivateStream) read(ctx context.Context, eventC chan interface{}) {
 						return
 
 					default:
+						s.Subscriptions = nil
 						err = s.connect(ctx)
 						time.Sleep(5 * time.Second)
 					}