diff --git a/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java b/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java
index e4f73cc..8274530 100644
--- a/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java
+++ b/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java
@@ -126,6 +126,7 @@ public void connect(@Nullable List<StompHeader> _headers) {
 
                         case CLOSED:
                             Log.d(TAG, "Socket closed");
+                            lifecyclePublishSubject.onNext(lifecycleEvent);
                             disconnect();
                             break;