Return old subscribe method without headers

NaikSoftware · Nov 27, 2016 · 125acb5 · 125acb5
1 parent 4664650
commit 125acb5
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java b/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java
@@ -147,6 +147,10 @@ public void disconnect() {
         mConnected = false;
     }
 
+    public Observable<StompMessage> topic(String destinationPath) {
+        return topic(destinationPath, null);
+    }
+
     public Observable<StompMessage> topic(String destinationPath, List<StompHeader> headerList) {
        return Observable.<StompMessage>create(subscriber -> {
            Set<Subscriber<? super StompMessage>> subscribersSet = mSubscribers.get(destinationPath);
@@ -183,9 +187,7 @@ private void subscribePath(String destinationPath, List<StompHeader> headerList)
           headers.add(new StompHeader(StompHeader.ID, topicId));
           headers.add(new StompHeader(StompHeader.DESTINATION, destinationPath));
           headers.add(new StompHeader(StompHeader.ACK, DEFAULT_ACK));
-          for(StompHeader header : headerList){
-              headers.add(header);
-          }
+          if (headerList != null) headers.addAll(headerList);
           send(new StompMessage(StompCommand.SUBSCRIBE,
                   headers, null));
       }