Committed by Github action

master: {
  "stompjs": "6.1.0",
  "rx-stomp": "1.0.2",
  "ng2-stompjs": "8.0.0"
}
develop: {
  "stompjs": "6.1.0",
  "rx-stomp": "1.0.2",
  "ng2-stompjs": "8.0.0"
}

Author: kum-deepak

api-docs/develop/classes/RxStomp.html

@@ -1188,7 +1188,7 @@ <h3 id="methods">
 
                         <tr>
                             <td class="col-md-4">
-                                    <div class="io-line">Defined in <a href="" data-line="580" class="link-to-prism">consolidated/rx-stomp/src/rx-stomp.ts:580</a></div>
+                                    <div class="io-line">Defined in <a href="" data-line="584" class="link-to-prism">consolidated/rx-stomp/src/rx-stomp.ts:584</a></div>
                             </td>
                         </tr>
 
@@ -1861,16 +1861,20 @@ <h3 id="accessors">
 
       if (params.subscribeOnlyOnce) {
         connectedPre$ &#x3D; connectedPre$.pipe(take(1));
-      }
+      }    
 
       stompConnectedSubscription &#x3D; connectedPre$.subscribe(() &#x3D;&gt; {
         this._debug(&#x60;Will subscribe to ${params.destination}&#x60;);
+        let subHeaders &#x3D; params.subHeaders;
+        if (typeof subHeaders &#x3D;&#x3D;&#x3D; &#x27;function&#x27;) {
+          subHeaders &#x3D; subHeaders();
+        }          
         stompSubscription &#x3D; this._stompClient.subscribe(
           params.destination,
           (message: IMessage) &#x3D;&gt; {
             messages.next(message);
           },
-          params.subHeaders
+          subHeaders
         );
       });
 

api-docs/develop/interfaces/IWatchParams.html

@@ -164,15 +164,15 @@ <h3 id="inputs">Properties</h3>
                                 </tr>
                                 <tr>
                                     <td class="col-md-4">
-                                        <code>subHeaders:     <code><a href="../classes/StompHeaders.html" target="_self" >StompHeaders</a></code>
+                                        <code>subHeaders:     <code><a href="../classes/StompHeaders.html" target="_self" >StompHeaders | </a></code>
 </code>
                                     </td>
                                 </tr>
 
 
                                     <tr>
                                         <td class="col-md-4">
-                                            <i>Type : </i>    <code><a href="../classes/StompHeaders.html" target="_self" >StompHeaders</a></code>
+                                            <i>Type : </i>    <code><a href="../classes/StompHeaders.html" target="_self" >StompHeaders | </a></code>
 
                                         </td>
                                     </tr>
@@ -189,7 +189,17 @@ <h3 id="inputs">Properties</h3>
                             <tr>
                                 <td class="col-md-4">
                                     <div class="io-description"><p>Subscription headers, defaults to <code>{}</code></p>
-</div>
+<p>If header information can change over time and you are allowing automatic resubscriptions,
+consider using a callback as the value rather than a string literal.</p>
+<div><pre class="line-numbers"><code class="language-typescript">   *              const subHeadersCallback = () =&gt; {
+   *                  return {bye: &#39;world&#39;};
+   *              };
+   *              const sub = rxStomp.watch({ destination: queueName, subHeaders: subHeadersCallback})
+   *                                 .subscribe((message) =&gt; {
+   *                                    // handle message
+   *                                 });
+   *              // The subHeadersCallback will be invoked before every (re)subscription.
+   *</code></pre></div></div>
                                 </td>
                             </tr>
                         </tbody>
@@ -307,8 +317,22 @@ <h3 id="inputs">Properties</h3>
 
   /**
    * Subscription headers, defaults to &#x60;{}&#x60;
+   * 
+   * If header information can change over time and you are allowing automatic resubscriptions,
+   * consider using a callback as the value rather than a string literal.
+   *
+   * &#x60;&#x60;&#x60;typescript
+   *              const subHeadersCallback &#x3D; () &#x3D;&gt; {
+   *                  return {bye: &#x27;world&#x27;};
+   *              };
+   *              const sub &#x3D; rxStomp.watch({ destination: queueName, subHeaders: subHeadersCallback})
+   *                                 .subscribe((message) &#x3D;&gt; {
+   *                                    // handle message
+   *                                 });
+   *              // The subHeadersCallback will be invoked before every (re)subscription.
+   * &#x60;&#x60;&#x60;
    */
-  readonly subHeaders?: StompHeaders;
+  readonly subHeaders?: StompHeaders | (() &#x3D;&gt; StompHeaders);
 
   /**
    * Headers to be passed while unsubscribing, defaults to &#x60;{}&#x60;.