Add extra logs

Author: NaikSoftware

lib/src/main/java/ua/naiksoftware/stomp/AbstractConnectionProvider.java

@@ -31,6 +31,7 @@ abstract class AbstractConnectionProvider implements ConnectionProvider {
     @NonNull
     @Override
     public Observable<String> messages() {
+        Log.d(TAG, "messages()");
         return mMessagesStream.startWith(initSocket().toObservable());
     }
 
@@ -51,6 +52,7 @@ public Completable disconnect() {
     }
 
     private Completable initSocket() {
+        Log.d(TAG, "innitSocket");
         return Completable
                 .fromAction(this::createWebSocketConnection);
     }

lib/src/main/java/ua/naiksoftware/stomp/OkHttpConnectionProvider.java

@@ -1,5 +1,6 @@
 package ua.naiksoftware.stomp;
 
+import android.nfc.Tag;
 import android.support.annotation.NonNull;
 import android.support.annotation.Nullable;
 import android.util.Log;
@@ -18,11 +19,12 @@
 
 class OkHttpConnectionProvider extends AbstractConnectionProvider {
 
+    public static final String TAG = "OkHttpConnProvider";
+
     private final String mUri;
     @NonNull
     private final Map<String, String> mConnectHttpHeaders;
     private final OkHttpClient mOkHttpClient;
-    private final String tag = OkHttpConnectionProvider.class.getSimpleName();
 
     @Nullable
     private WebSocket openedSocked;
@@ -44,6 +46,7 @@ public void rawDisconnect() {
 
     @Override
     void createWebSocketConnection() {
+        Log.d(TAG, "createWebSocketConnection");
         Request.Builder requestBuilder = new Request.Builder()
                 .url(mUri);
 
@@ -53,6 +56,7 @@ void createWebSocketConnection() {
                 new WebSocketListener() {
                     @Override
                     public void onOpen(WebSocket webSocket, @NonNull Response response) {
+                        Log.d(TAG, "onOpen");
                         LifecycleEvent openEvent = new LifecycleEvent(LifecycleEvent.Type.OPENED);
 
                         TreeMap<String, String> headersAsMap = headersAsMap(response);
@@ -64,7 +68,7 @@ public void onOpen(WebSocket webSocket, @NonNull Response response) {
                     @Override
                     public void onMessage(WebSocket webSocket, String text) {
                         if (text.equals("\n"))
-                            Log.d(tag, "RECEIVED HEARTBEAT");
+                            Log.d(TAG, "RECEIVED HEARTBEAT");
                         else
                             emitMessage(text);
                     }
@@ -76,25 +80,29 @@ public void onMessage(WebSocket webSocket, @NonNull ByteString bytes) {
 
                     @Override
                     public void onClosed(WebSocket webSocket, int code, String reason) {
+                        Log.d(TAG, "onClosed (nullify socket)");
                         openedSocked = null;
                         emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
                     }
 
                     @Override
                     public void onFailure(WebSocket webSocket, Throwable t, Response response) {
                         // in OkHttp, a Failure is equivalent to a JWS-Error *and* a JWS-Close
+                        Log.d(TAG, "onFailure (nullify socket)");
                         emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.ERROR, new Exception(t)));
                         openedSocked = null;
                         emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
                     }
 
                     @Override
                     public void onClosing(final WebSocket webSocket, final int code, final String reason) {
+                        Log.d(TAG, "onClosing");
                         webSocket.close(code, reason);
                     }
                 }
 
         );
+        Log.d(TAG, "Socket inited " + openedSocked);
     }
 
     @Override

lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java

@@ -100,13 +100,20 @@ public void connect() {
      * @param _headers HTTP headers to send in the INITIAL REQUEST, i.e. during the protocol upgrade
      */
     public void connect(@Nullable List<StompHeader> _headers) {
+
+        Log.d(TAG, "Connect");
+
         mHeaders = _headers;
 
-        if (mConnected) return;
+        if (mConnected) {
+            Log.d(TAG, "Already connected, ignore");
+            return;
+        }
         mLifecycleDisposable = mConnectionProvider.lifecycle()
                 .subscribe(lifecycleEvent -> {
                     switch (lifecycleEvent.getType()) {
                         case OPENED:
+                            Log.d(TAG, "Socket connected, send connect command to stomp");
                             List<StompHeader> headers = new ArrayList<>();
                             headers.add(new StompHeader(StompHeader.VERSION, SUPPORTED_VERSIONS));
                             headers.add(new StompHeader(StompHeader.HEART_BEAT, "0," + heartbeat));
@@ -116,17 +123,20 @@ public void connect(@Nullable List<StompHeader> _headers) {
                             break;
 
                         case CLOSED:
+                            Log.d(TAG, "Socket closed");
                             setConnected(false);
                             isConnecting = false;
                             break;
 
                         case ERROR:
+                            Log.d(TAG, "Socket closed with error");
                             setConnected(false);
                             isConnecting = false;
                             break;
                     }
                 });
 
+        Log.d(TAG, "Subscribe to messages for create connection");
         isConnecting = true;
         mMessagesDisposable = mConnectionProvider.messages()
                 .map(StompMessage::from)