| <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "https://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> |
| <html xmlns="http://www.w3.org/1999/xhtml" lang="en-US"> |
| <head> |
| <meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/> |
| <meta http-equiv="X-UA-Compatible" content="IE=11"/> |
| <meta name="generator" content="Doxygen 1.9.7"/> |
| <meta name="viewport" content="width=device-width, initial-scale=1"/> |
| <title>pulsar-client-cpp: include/pulsar/Consumer.h Source File</title> |
| <link href="tabs.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="jquery.js"></script> |
| <script type="text/javascript" src="dynsections.js"></script> |
| <link href="search/search.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="search/searchdata.js"></script> |
| <script type="text/javascript" src="search/search.js"></script> |
| <script type="text/javascript" src="darkmode_toggle.js"></script> |
| <link href="doxygen.css" rel="stylesheet" type="text/css" /> |
| </head> |
| <body> |
| <div id="top"><!-- do not remove this div, it is closed by doxygen! --> |
| <div id="titlearea"> |
| <table cellspacing="0" cellpadding="0"> |
| <tbody> |
| <tr id="projectrow"> |
| <td id="projectalign"> |
| <div id="projectname">pulsar-client-cpp |
| </div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </div> |
| <!-- end header part --> |
| <!-- Generated by Doxygen 1.9.7 --> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&dn=expat.txt MIT */ |
| var searchBox = new SearchBox("searchBox", "search/",'.html'); |
| /* @license-end */ |
| </script> |
| <script type="text/javascript" src="menudata.js"></script> |
| <script type="text/javascript" src="menu.js"></script> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&dn=expat.txt MIT */ |
| $(function() { |
| initMenu('',true,false,'search.php','Search'); |
| $(document).ready(function() { init_search(); }); |
| }); |
| /* @license-end */ |
| </script> |
| <div id="main-nav"></div> |
| <!-- window showing the filter options --> |
| <div id="MSearchSelectWindow" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| onkeydown="return searchBox.OnSearchSelectKey(event)"> |
| </div> |
| |
| <!-- iframe showing the search results (closed by default) --> |
| <div id="MSearchResultsWindow"> |
| <div id="MSearchResults"> |
| <div class="SRPage"> |
| <div id="SRIndex"> |
| <div id="SRResults"></div> |
| <div class="SRStatus" id="Loading">Loading...</div> |
| <div class="SRStatus" id="Searching">Searching...</div> |
| <div class="SRStatus" id="NoMatches">No Matches</div> |
| </div> |
| </div> |
| </div> |
| </div> |
| |
| <div id="nav-path" class="navpath"> |
| <ul> |
| <li class="navelem"><a class="el" href="dir_d44c64559bbebec7f509842c48db8b23.html">include</a></li><li class="navelem"><a class="el" href="dir_84093bac216bb6272e4432021f1ca7f4.html">pulsar</a></li> </ul> |
| </div> |
| </div><!-- top --> |
| <div class="header"> |
| <div class="headertitle"><div class="title">Consumer.h</div></div> |
| </div><!--header--> |
| <div class="contents"> |
| <div class="fragment"><div class="line"><a id="l00001" name="l00001"></a><span class="lineno"> 1</span> </div> |
| <div class="line"><a id="l00019" name="l00019"></a><span class="lineno"> 19</span><span class="preprocessor">#ifndef CONSUMER_HPP_</span></div> |
| <div class="line"><a id="l00020" name="l00020"></a><span class="lineno"> 20</span><span class="preprocessor">#define CONSUMER_HPP_</span></div> |
| <div class="line"><a id="l00021" name="l00021"></a><span class="lineno"> 21</span> </div> |
| <div class="line"><a id="l00022" name="l00022"></a><span class="lineno"> 22</span><span class="preprocessor">#include <pulsar/BrokerConsumerStats.h></span></div> |
| <div class="line"><a id="l00023" name="l00023"></a><span class="lineno"> 23</span><span class="preprocessor">#include <pulsar/ConsumerConfiguration.h></span></div> |
| <div class="line"><a id="l00024" name="l00024"></a><span class="lineno"> 24</span><span class="preprocessor">#include <pulsar/TypedMessage.h></span></div> |
| <div class="line"><a id="l00025" name="l00025"></a><span class="lineno"> 25</span><span class="preprocessor">#include <pulsar/defines.h></span></div> |
| <div class="line"><a id="l00026" name="l00026"></a><span class="lineno"> 26</span> </div> |
| <div class="line"><a id="l00027" name="l00027"></a><span class="lineno"> 27</span><span class="preprocessor">#include <iostream></span></div> |
| <div class="line"><a id="l00028" name="l00028"></a><span class="lineno"> 28</span> </div> |
| <div class="line"><a id="l00029" name="l00029"></a><span class="lineno"> 29</span><span class="keyword">namespace </span><a class="code hl_namespace" href="namespacepulsar.html">pulsar</a> {</div> |
| <div class="line"><a id="l00030" name="l00030"></a><span class="lineno"> 30</span><span class="keyword">class </span>PulsarWrapper;</div> |
| <div class="line"><a id="l00031" name="l00031"></a><span class="lineno"> 31</span><span class="keyword">class </span>ConsumerImplBase;</div> |
| <div class="line"><a id="l00032" name="l00032"></a><span class="lineno"> 32</span><span class="keyword">class </span>PulsarFriend;</div> |
| <div class="line"><a id="l00033" name="l00033"></a><span class="lineno"> 33</span><span class="keyword">typedef</span> std::shared_ptr<ConsumerImplBase> ConsumerImplBasePtr;</div> |
| <div class="line"><a id="l00037" name="l00037"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html"> 37</a></span><span class="keyword">class </span>PULSAR_PUBLIC <a class="code hl_class" href="classpulsar_1_1_consumer.html">Consumer</a> {</div> |
| <div class="line"><a id="l00038" name="l00038"></a><span class="lineno"> 38</span> <span class="keyword">public</span>:</div> |
| <div class="line"><a id="l00042" name="l00042"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#afe59503d5d5309f38d4e246bd9f435b4"> 42</a></span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#afe59503d5d5309f38d4e246bd9f435b4">Consumer</a>();</div> |
| <div class="line"><a id="l00043" name="l00043"></a><span class="lineno"> 43</span> <span class="keyword">virtual</span> <a class="code hl_class" href="classpulsar_1_1_consumer.html">~Consumer</a>() = <span class="keywordflow">default</span>;</div> |
| <div class="line"><a id="l00044" name="l00044"></a><span class="lineno"> 44</span> </div> |
| <div class="line"><a id="l00048" name="l00048"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ad55d95cd75501562d8ae6d83935d5977"> 48</a></span> <span class="keyword">const</span> std::string& <a class="code hl_function" href="classpulsar_1_1_consumer.html#ad55d95cd75501562d8ae6d83935d5977">getTopic</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a id="l00049" name="l00049"></a><span class="lineno"> 49</span> </div> |
| <div class="line"><a id="l00053" name="l00053"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#af6049caaf3e1f8bc91d4dc52b02ab7d1"> 53</a></span> <span class="keyword">const</span> std::string& <a class="code hl_function" href="classpulsar_1_1_consumer.html#af6049caaf3e1f8bc91d4dc52b02ab7d1">getSubscriptionName</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a id="l00054" name="l00054"></a><span class="lineno"> 54</span> </div> |
| <div class="line"><a id="l00068" name="l00068"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a542ca0a9473a03ccf8bd8aeed24de490"> 68</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a542ca0a9473a03ccf8bd8aeed24de490">unsubscribe</a>();</div> |
| <div class="line"><a id="l00069" name="l00069"></a><span class="lineno"> 69</span> </div> |
| <div class="line"><a id="l00081" name="l00081"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a8691920cae838418f33f13690a72771d"> 81</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a8691920cae838418f33f13690a72771d">unsubscribeAsync</a>(<a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00082" name="l00082"></a><span class="lineno"> 82</span> </div> |
| <div class="line"><a id="l00093" name="l00093"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#abc8cec6e81c582c6af8e3d931e41a2ad"> 93</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#abc8cec6e81c582c6af8e3d931e41a2ad">receive</a>(<a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& msg);</div> |
| <div class="line"><a id="l00094" name="l00094"></a><span class="lineno"> 94</span> </div> |
| <div class="line"><a id="l00095" name="l00095"></a><span class="lineno"> 95</span> <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a id="l00096" name="l00096"></a><span class="lineno"> 96</span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> receive(<a class="code hl_class" href="classpulsar_1_1_typed_message.html">TypedMessage<T></a>& msg, <span class="keyword">typename</span> TypedMessage<T>::Decoder decoder) {</div> |
| <div class="line"><a id="l00097" name="l00097"></a><span class="lineno"> 97</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a> rawMsg;</div> |
| <div class="line"><a id="l00098" name="l00098"></a><span class="lineno"> 98</span> <span class="keyword">auto</span> result = receive(rawMsg);</div> |
| <div class="line"><a id="l00099" name="l00099"></a><span class="lineno"> 99</span> msg = <a class="code hl_class" href="classpulsar_1_1_typed_message.html">TypedMessage<T></a>{rawMsg, decoder};</div> |
| <div class="line"><a id="l00100" name="l00100"></a><span class="lineno"> 100</span> <span class="keywordflow">return</span> result;</div> |
| <div class="line"><a id="l00101" name="l00101"></a><span class="lineno"> 101</span> }</div> |
| <div class="line"><a id="l00102" name="l00102"></a><span class="lineno"> 102</span> </div> |
| <div class="line"><a id="l00111" name="l00111"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ace9475b70f37c91df5b442f41058370e"> 111</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#ace9475b70f37c91df5b442f41058370e">receive</a>(<a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& msg, <span class="keywordtype">int</span> timeoutMs);</div> |
| <div class="line"><a id="l00112" name="l00112"></a><span class="lineno"> 112</span> </div> |
| <div class="line"><a id="l00113" name="l00113"></a><span class="lineno"> 113</span> <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a id="l00114" name="l00114"></a><span class="lineno"> 114</span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> receive(<a class="code hl_class" href="classpulsar_1_1_typed_message.html">TypedMessage<T></a>& msg, <span class="keywordtype">int</span> timeoutMs, <span class="keyword">typename</span> TypedMessage<T>::Decoder decoder) {</div> |
| <div class="line"><a id="l00115" name="l00115"></a><span class="lineno"> 115</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a> rawMsg;</div> |
| <div class="line"><a id="l00116" name="l00116"></a><span class="lineno"> 116</span> <span class="keyword">auto</span> result = receive(rawMsg, timeoutMs);</div> |
| <div class="line"><a id="l00117" name="l00117"></a><span class="lineno"> 117</span> msg = <a class="code hl_class" href="classpulsar_1_1_typed_message.html">TypedMessage<T></a>{rawMsg, decoder};</div> |
| <div class="line"><a id="l00118" name="l00118"></a><span class="lineno"> 118</span> <span class="keywordflow">return</span> result;</div> |
| <div class="line"><a id="l00119" name="l00119"></a><span class="lineno"> 119</span> }</div> |
| <div class="line"><a id="l00120" name="l00120"></a><span class="lineno"> 120</span> </div> |
| <div class="line"><a id="l00132" name="l00132"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a0189416fb8672b23919276cc9f1bba5d"> 132</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a0189416fb8672b23919276cc9f1bba5d">receiveAsync</a>(ReceiveCallback callback);</div> |
| <div class="line"><a id="l00133" name="l00133"></a><span class="lineno"> 133</span> </div> |
| <div class="line"><a id="l00134" name="l00134"></a><span class="lineno"> 134</span> <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a id="l00135" name="l00135"></a><span class="lineno"> 135</span> <span class="keywordtype">void</span> receiveAsync(std::function<<span class="keywordtype">void</span>(<a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result, <span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_typed_message.html">TypedMessage<T></a>&)> callback,</div> |
| <div class="line"><a id="l00136" name="l00136"></a><span class="lineno"> 136</span> <span class="keyword">typename</span> TypedMessage<T>::Decoder decoder) {</div> |
| <div class="line"><a id="l00137" name="l00137"></a><span class="lineno"> 137</span> receiveAsync([callback, decoder](<a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result, <span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& msg) {</div> |
| <div class="line"><a id="l00138" name="l00138"></a><span class="lineno"> 138</span> callback(result, <a class="code hl_class" href="classpulsar_1_1_typed_message.html">TypedMessage<T></a>{msg, decoder});</div> |
| <div class="line"><a id="l00139" name="l00139"></a><span class="lineno"> 139</span> });</div> |
| <div class="line"><a id="l00140" name="l00140"></a><span class="lineno"> 140</span> }</div> |
| <div class="line"><a id="l00141" name="l00141"></a><span class="lineno"> 141</span> </div> |
| <div class="line"><a id="l00152" name="l00152"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a49c846a386d778df94a1439982be5cbd"> 152</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a49c846a386d778df94a1439982be5cbd">batchReceive</a>(<a class="code hl_typedef" href="namespacepulsar.html#ac87806090d752fb2248e8da65727630a">Messages</a>& msgs);</div> |
| <div class="line"><a id="l00153" name="l00153"></a><span class="lineno"> 153</span> </div> |
| <div class="line"><a id="l00165" name="l00165"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ac403fe5941453dcfc41cc01055bca16e"> 165</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#ac403fe5941453dcfc41cc01055bca16e">batchReceiveAsync</a>(BatchReceiveCallback callback);</div> |
| <div class="line"><a id="l00166" name="l00166"></a><span class="lineno"> 166</span> </div> |
| <div class="line"><a id="l00178" name="l00178"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3c3eb5056f228d281798f9ea75f52af9"> 178</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a3c3eb5056f228d281798f9ea75f52af9">acknowledge</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& message);</div> |
| <div class="line"><a id="l00179" name="l00179"></a><span class="lineno"> 179</span> </div> |
| <div class="line"><a id="l00190" name="l00190"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#aed10e043835e50d8129e6adecd91da72"> 190</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#aed10e043835e50d8129e6adecd91da72">acknowledge</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId);</div> |
| <div class="line"><a id="l00191" name="l00191"></a><span class="lineno"> 191</span> </div> |
| <div class="line"><a id="l00196" name="l00196"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a57fd2c53a44ea53262742d90ff11e0fd"> 196</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a57fd2c53a44ea53262742d90ff11e0fd">acknowledge</a>(<span class="keyword">const</span> MessageIdList& messageIdList);</div> |
| <div class="line"><a id="l00197" name="l00197"></a><span class="lineno"> 197</span> </div> |
| <div class="line"><a id="l00207" name="l00207"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a867bebab981d5aa2f74217308aa2353c"> 207</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a867bebab981d5aa2f74217308aa2353c">acknowledgeAsync</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& message, <a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00208" name="l00208"></a><span class="lineno"> 208</span> </div> |
| <div class="line"><a id="l00218" name="l00218"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3a08b7cdcc9a1733ce7066173bfcdc28"> 218</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a3a08b7cdcc9a1733ce7066173bfcdc28">acknowledgeAsync</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId, <a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00219" name="l00219"></a><span class="lineno"> 219</span> </div> |
| <div class="line"><a id="l00226" name="l00226"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a74283a098beeb002e15a1dbba9fcff13"> 226</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a74283a098beeb002e15a1dbba9fcff13">acknowledgeAsync</a>(<span class="keyword">const</span> MessageIdList& messageIdList, <a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00227" name="l00227"></a><span class="lineno"> 227</span> </div> |
| <div class="line"><a id="l00245" name="l00245"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3eb0b0db2da0628da15d3f242e254f6d"> 245</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a3eb0b0db2da0628da15d3f242e254f6d">acknowledgeCumulative</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& message);</div> |
| <div class="line"><a id="l00246" name="l00246"></a><span class="lineno"> 246</span> </div> |
| <div class="line"><a id="l00263" name="l00263"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a79558de7435fd0b6ca0bde84f3061822"> 263</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a79558de7435fd0b6ca0bde84f3061822">acknowledgeCumulative</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId);</div> |
| <div class="line"><a id="l00264" name="l00264"></a><span class="lineno"> 264</span> </div> |
| <div class="line"><a id="l00275" name="l00275"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a6ad164b1ab4449b17bce764224e92960"> 275</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a6ad164b1ab4449b17bce764224e92960">acknowledgeCumulativeAsync</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& message, <a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00276" name="l00276"></a><span class="lineno"> 276</span> </div> |
| <div class="line"><a id="l00287" name="l00287"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a5d4cf148f372618961fd3411792a5cd7"> 287</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a5d4cf148f372618961fd3411792a5cd7">acknowledgeCumulativeAsync</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId, <a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00288" name="l00288"></a><span class="lineno"> 288</span> </div> |
| <div class="line"><a id="l00319" name="l00319"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3cd227d9be2ae090c3a55bcdfff1df69"> 319</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a3cd227d9be2ae090c3a55bcdfff1df69">negativeAcknowledge</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a>& message);</div> |
| <div class="line"><a id="l00320" name="l00320"></a><span class="lineno"> 320</span> </div> |
| <div class="line"><a id="l00351" name="l00351"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#afd631d1c357bc0284afe3e0cd2acbd6e"> 351</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#afd631d1c357bc0284afe3e0cd2acbd6e">negativeAcknowledge</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId);</div> |
| <div class="line"><a id="l00352" name="l00352"></a><span class="lineno"> 352</span> </div> |
| <div class="line"><a id="l00356" name="l00356"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a8b01803221c283e4df21715aeb024b84"> 356</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a8b01803221c283e4df21715aeb024b84">close</a>();</div> |
| <div class="line"><a id="l00357" name="l00357"></a><span class="lineno"> 357</span> </div> |
| <div class="line"><a id="l00362" name="l00362"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a1b4539f46eb42170a550d6cd9076d8d7"> 362</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a1b4539f46eb42170a550d6cd9076d8d7">closeAsync</a>(<a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00363" name="l00363"></a><span class="lineno"> 363</span> </div> |
| <div class="line"><a id="l00367" name="l00367"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a7370b7a19a08fdff5b044e74ad8bd679"> 367</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a7370b7a19a08fdff5b044e74ad8bd679">pauseMessageListener</a>();</div> |
| <div class="line"><a id="l00368" name="l00368"></a><span class="lineno"> 368</span> </div> |
| <div class="line"><a id="l00373" name="l00373"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a02a9a412f1aa7f1ec8dc0c0134315b66"> 373</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a02a9a412f1aa7f1ec8dc0c0134315b66">resumeMessageListener</a>();</div> |
| <div class="line"><a id="l00374" name="l00374"></a><span class="lineno"> 374</span> </div> |
| <div class="line"><a id="l00384" name="l00384"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3d60ee12b0e9766d60c3a8e08a61287a"> 384</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a3d60ee12b0e9766d60c3a8e08a61287a">redeliverUnacknowledgedMessages</a>();</div> |
| <div class="line"><a id="l00385" name="l00385"></a><span class="lineno"> 385</span> </div> |
| <div class="line"><a id="l00398" name="l00398"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a617639e11e05ecba3d013d831578d19d"> 398</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a617639e11e05ecba3d013d831578d19d">getBrokerConsumerStats</a>(<a class="code hl_class" href="classpulsar_1_1_broker_consumer_stats.html">BrokerConsumerStats</a>& brokerConsumerStats);</div> |
| <div class="line"><a id="l00399" name="l00399"></a><span class="lineno"> 399</span> </div> |
| <div class="line"><a id="l00411" name="l00411"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a01e55f7906b6922fa069d84f5459af4b"> 411</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a01e55f7906b6922fa069d84f5459af4b">getBrokerConsumerStatsAsync</a>(BrokerConsumerStatsCallback callback);</div> |
| <div class="line"><a id="l00412" name="l00412"></a><span class="lineno"> 412</span> </div> |
| <div class="line"><a id="l00423" name="l00423"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a45800c18df817caabe6cd9c21e7d72b3"> 423</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a45800c18df817caabe6cd9c21e7d72b3">seek</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId);</div> |
| <div class="line"><a id="l00424" name="l00424"></a><span class="lineno"> 424</span> </div> |
| <div class="line"><a id="l00431" name="l00431"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ae6835e612b61795a13eff5fd2da85a0e"> 431</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#ae6835e612b61795a13eff5fd2da85a0e">seek</a>(uint64_t timestamp);</div> |
| <div class="line"><a id="l00432" name="l00432"></a><span class="lineno"> 432</span> </div> |
| <div class="line"><a id="l00443" name="l00443"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#af1c892616483868ce5e30be46e7a40bf"> 443</a></span> <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#af1c892616483868ce5e30be46e7a40bf">seekAsync</a>(<span class="keyword">const</span> <a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId, <a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00444" name="l00444"></a><span class="lineno"> 444</span> </div> |
| <div class="line"><a id="l00451" name="l00451"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a01761bcf98436600d5f4d461582db94f"> 451</a></span> <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a01761bcf98436600d5f4d461582db94f">seekAsync</a>(uint64_t timestamp, <a class="code hl_typedef" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> callback);</div> |
| <div class="line"><a id="l00452" name="l00452"></a><span class="lineno"> 452</span> </div> |
| <div class="line"><a id="l00456" name="l00456"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a95a69d39ec2c8714b6ffce0f6ab74a55"> 456</a></span> <span class="keywordtype">bool</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#a95a69d39ec2c8714b6ffce0f6ab74a55">isConnected</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a id="l00457" name="l00457"></a><span class="lineno"> 457</span> </div> |
| <div class="line"><a id="l00462" name="l00462"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#afbd9e4f5b33b5b10a32866d3485cbeb5"> 462</a></span> <span class="keywordtype">void</span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#afbd9e4f5b33b5b10a32866d3485cbeb5">getLastMessageIdAsync</a>(GetLastMessageIdCallback callback);</div> |
| <div class="line"><a id="l00463" name="l00463"></a><span class="lineno"> 463</span> </div> |
| <div class="line"><a id="l00467" name="l00467"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#af60a7e87b76e5c69ee0e14f6ec902908"> 467</a></span> <a class="code hl_enumeration" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> <a class="code hl_function" href="classpulsar_1_1_consumer.html#af60a7e87b76e5c69ee0e14f6ec902908">getLastMessageId</a>(<a class="code hl_class" href="classpulsar_1_1_message_id.html">MessageId</a>& messageId);</div> |
| <div class="line"><a id="l00468" name="l00468"></a><span class="lineno"> 468</span> </div> |
| <div class="line"><a id="l00469" name="l00469"></a><span class="lineno"> 469</span> <span class="keyword">private</span>:</div> |
| <div class="line"><a id="l00470" name="l00470"></a><span class="lineno"> 470</span> ConsumerImplBasePtr impl_;</div> |
| <div class="line"><a id="l00471" name="l00471"></a><span class="lineno"> 471</span> <span class="keyword">explicit</span> <a class="code hl_class" href="classpulsar_1_1_consumer.html">Consumer</a>(ConsumerImplBasePtr);</div> |
| <div class="line"><a id="l00472" name="l00472"></a><span class="lineno"> 472</span> </div> |
| <div class="line"><a id="l00473" name="l00473"></a><span class="lineno"> 473</span> <span class="keyword">friend</span> <span class="keyword">class </span>PulsarFriend;</div> |
| <div class="line"><a id="l00474" name="l00474"></a><span class="lineno"> 474</span> <span class="keyword">friend</span> <span class="keyword">class </span>PulsarWrapper;</div> |
| <div class="line"><a id="l00475" name="l00475"></a><span class="lineno"> 475</span> <span class="keyword">friend</span> <span class="keyword">class </span>MultiTopicsConsumerImpl;</div> |
| <div class="line"><a id="l00476" name="l00476"></a><span class="lineno"> 476</span> <span class="keyword">friend</span> <span class="keyword">class </span>ConsumerImpl;</div> |
| <div class="line"><a id="l00477" name="l00477"></a><span class="lineno"> 477</span> <span class="keyword">friend</span> <span class="keyword">class </span>ClientImpl;</div> |
| <div class="line"><a id="l00478" name="l00478"></a><span class="lineno"> 478</span> <span class="keyword">friend</span> <span class="keyword">class </span>ConsumerTest;</div> |
| <div class="line"><a id="l00479" name="l00479"></a><span class="lineno"> 479</span>};</div> |
| <div class="line"><a id="l00480" name="l00480"></a><span class="lineno"> 480</span>} <span class="comment">// namespace pulsar</span></div> |
| <div class="line"><a id="l00481" name="l00481"></a><span class="lineno"> 481</span> </div> |
| <div class="line"><a id="l00482" name="l00482"></a><span class="lineno"> 482</span><span class="preprocessor">#endif </span><span class="comment">/* CONSUMER_HPP_ */</span><span class="preprocessor"></span></div> |
| <div class="ttc" id="aclasspulsar_1_1_broker_consumer_stats_html"><div class="ttname"><a href="classpulsar_1_1_broker_consumer_stats.html">pulsar::BrokerConsumerStats</a></div><div class="ttdef"><b>Definition</b> BrokerConsumerStats.h:35</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html"><div class="ttname"><a href="classpulsar_1_1_consumer.html">pulsar::Consumer</a></div><div class="ttdef"><b>Definition</b> Consumer.h:37</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a01761bcf98436600d5f4d461582db94f"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a01761bcf98436600d5f4d461582db94f">pulsar::Consumer::seekAsync</a></div><div class="ttdeci">virtual void seekAsync(uint64_t timestamp, ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a0189416fb8672b23919276cc9f1bba5d"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a0189416fb8672b23919276cc9f1bba5d">pulsar::Consumer::receiveAsync</a></div><div class="ttdeci">void receiveAsync(ReceiveCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a01e55f7906b6922fa069d84f5459af4b"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a01e55f7906b6922fa069d84f5459af4b">pulsar::Consumer::getBrokerConsumerStatsAsync</a></div><div class="ttdeci">void getBrokerConsumerStatsAsync(BrokerConsumerStatsCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a02a9a412f1aa7f1ec8dc0c0134315b66"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a02a9a412f1aa7f1ec8dc0c0134315b66">pulsar::Consumer::resumeMessageListener</a></div><div class="ttdeci">Result resumeMessageListener()</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a1b4539f46eb42170a550d6cd9076d8d7"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a1b4539f46eb42170a550d6cd9076d8d7">pulsar::Consumer::closeAsync</a></div><div class="ttdeci">void closeAsync(ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a3a08b7cdcc9a1733ce7066173bfcdc28"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a3a08b7cdcc9a1733ce7066173bfcdc28">pulsar::Consumer::acknowledgeAsync</a></div><div class="ttdeci">void acknowledgeAsync(const MessageId &messageId, ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a3c3eb5056f228d281798f9ea75f52af9"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a3c3eb5056f228d281798f9ea75f52af9">pulsar::Consumer::acknowledge</a></div><div class="ttdeci">Result acknowledge(const Message &message)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a3cd227d9be2ae090c3a55bcdfff1df69"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a3cd227d9be2ae090c3a55bcdfff1df69">pulsar::Consumer::negativeAcknowledge</a></div><div class="ttdeci">void negativeAcknowledge(const Message &message)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a3d60ee12b0e9766d60c3a8e08a61287a"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a3d60ee12b0e9766d60c3a8e08a61287a">pulsar::Consumer::redeliverUnacknowledgedMessages</a></div><div class="ttdeci">void redeliverUnacknowledgedMessages()</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a3eb0b0db2da0628da15d3f242e254f6d"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a3eb0b0db2da0628da15d3f242e254f6d">pulsar::Consumer::acknowledgeCumulative</a></div><div class="ttdeci">Result acknowledgeCumulative(const Message &message)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a45800c18df817caabe6cd9c21e7d72b3"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a45800c18df817caabe6cd9c21e7d72b3">pulsar::Consumer::seek</a></div><div class="ttdeci">Result seek(const MessageId &messageId)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a49c846a386d778df94a1439982be5cbd"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a49c846a386d778df94a1439982be5cbd">pulsar::Consumer::batchReceive</a></div><div class="ttdeci">Result batchReceive(Messages &msgs)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a542ca0a9473a03ccf8bd8aeed24de490"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a542ca0a9473a03ccf8bd8aeed24de490">pulsar::Consumer::unsubscribe</a></div><div class="ttdeci">Result unsubscribe()</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a57fd2c53a44ea53262742d90ff11e0fd"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a57fd2c53a44ea53262742d90ff11e0fd">pulsar::Consumer::acknowledge</a></div><div class="ttdeci">Result acknowledge(const MessageIdList &messageIdList)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a5d4cf148f372618961fd3411792a5cd7"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a5d4cf148f372618961fd3411792a5cd7">pulsar::Consumer::acknowledgeCumulativeAsync</a></div><div class="ttdeci">void acknowledgeCumulativeAsync(const MessageId &messageId, ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a617639e11e05ecba3d013d831578d19d"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a617639e11e05ecba3d013d831578d19d">pulsar::Consumer::getBrokerConsumerStats</a></div><div class="ttdeci">Result getBrokerConsumerStats(BrokerConsumerStats &brokerConsumerStats)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a6ad164b1ab4449b17bce764224e92960"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a6ad164b1ab4449b17bce764224e92960">pulsar::Consumer::acknowledgeCumulativeAsync</a></div><div class="ttdeci">void acknowledgeCumulativeAsync(const Message &message, ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a7370b7a19a08fdff5b044e74ad8bd679"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a7370b7a19a08fdff5b044e74ad8bd679">pulsar::Consumer::pauseMessageListener</a></div><div class="ttdeci">Result pauseMessageListener()</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a74283a098beeb002e15a1dbba9fcff13"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a74283a098beeb002e15a1dbba9fcff13">pulsar::Consumer::acknowledgeAsync</a></div><div class="ttdeci">void acknowledgeAsync(const MessageIdList &messageIdList, ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a79558de7435fd0b6ca0bde84f3061822"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a79558de7435fd0b6ca0bde84f3061822">pulsar::Consumer::acknowledgeCumulative</a></div><div class="ttdeci">Result acknowledgeCumulative(const MessageId &messageId)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a867bebab981d5aa2f74217308aa2353c"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a867bebab981d5aa2f74217308aa2353c">pulsar::Consumer::acknowledgeAsync</a></div><div class="ttdeci">void acknowledgeAsync(const Message &message, ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a8691920cae838418f33f13690a72771d"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a8691920cae838418f33f13690a72771d">pulsar::Consumer::unsubscribeAsync</a></div><div class="ttdeci">void unsubscribeAsync(ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a8b01803221c283e4df21715aeb024b84"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a8b01803221c283e4df21715aeb024b84">pulsar::Consumer::close</a></div><div class="ttdeci">Result close()</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_a95a69d39ec2c8714b6ffce0f6ab74a55"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a95a69d39ec2c8714b6ffce0f6ab74a55">pulsar::Consumer::isConnected</a></div><div class="ttdeci">bool isConnected() const</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_abc8cec6e81c582c6af8e3d931e41a2ad"><div class="ttname"><a href="classpulsar_1_1_consumer.html#abc8cec6e81c582c6af8e3d931e41a2ad">pulsar::Consumer::receive</a></div><div class="ttdeci">Result receive(Message &msg)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_ac403fe5941453dcfc41cc01055bca16e"><div class="ttname"><a href="classpulsar_1_1_consumer.html#ac403fe5941453dcfc41cc01055bca16e">pulsar::Consumer::batchReceiveAsync</a></div><div class="ttdeci">void batchReceiveAsync(BatchReceiveCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_ace9475b70f37c91df5b442f41058370e"><div class="ttname"><a href="classpulsar_1_1_consumer.html#ace9475b70f37c91df5b442f41058370e">pulsar::Consumer::receive</a></div><div class="ttdeci">Result receive(Message &msg, int timeoutMs)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_ad55d95cd75501562d8ae6d83935d5977"><div class="ttname"><a href="classpulsar_1_1_consumer.html#ad55d95cd75501562d8ae6d83935d5977">pulsar::Consumer::getTopic</a></div><div class="ttdeci">const std::string & getTopic() const</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_ae6835e612b61795a13eff5fd2da85a0e"><div class="ttname"><a href="classpulsar_1_1_consumer.html#ae6835e612b61795a13eff5fd2da85a0e">pulsar::Consumer::seek</a></div><div class="ttdeci">Result seek(uint64_t timestamp)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_aed10e043835e50d8129e6adecd91da72"><div class="ttname"><a href="classpulsar_1_1_consumer.html#aed10e043835e50d8129e6adecd91da72">pulsar::Consumer::acknowledge</a></div><div class="ttdeci">Result acknowledge(const MessageId &messageId)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_af1c892616483868ce5e30be46e7a40bf"><div class="ttname"><a href="classpulsar_1_1_consumer.html#af1c892616483868ce5e30be46e7a40bf">pulsar::Consumer::seekAsync</a></div><div class="ttdeci">virtual void seekAsync(const MessageId &messageId, ResultCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_af6049caaf3e1f8bc91d4dc52b02ab7d1"><div class="ttname"><a href="classpulsar_1_1_consumer.html#af6049caaf3e1f8bc91d4dc52b02ab7d1">pulsar::Consumer::getSubscriptionName</a></div><div class="ttdeci">const std::string & getSubscriptionName() const</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_af60a7e87b76e5c69ee0e14f6ec902908"><div class="ttname"><a href="classpulsar_1_1_consumer.html#af60a7e87b76e5c69ee0e14f6ec902908">pulsar::Consumer::getLastMessageId</a></div><div class="ttdeci">Result getLastMessageId(MessageId &messageId)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_afbd9e4f5b33b5b10a32866d3485cbeb5"><div class="ttname"><a href="classpulsar_1_1_consumer.html#afbd9e4f5b33b5b10a32866d3485cbeb5">pulsar::Consumer::getLastMessageIdAsync</a></div><div class="ttdeci">void getLastMessageIdAsync(GetLastMessageIdCallback callback)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_afd631d1c357bc0284afe3e0cd2acbd6e"><div class="ttname"><a href="classpulsar_1_1_consumer.html#afd631d1c357bc0284afe3e0cd2acbd6e">pulsar::Consumer::negativeAcknowledge</a></div><div class="ttdeci">void negativeAcknowledge(const MessageId &messageId)</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_consumer_html_afe59503d5d5309f38d4e246bd9f435b4"><div class="ttname"><a href="classpulsar_1_1_consumer.html#afe59503d5d5309f38d4e246bd9f435b4">pulsar::Consumer::Consumer</a></div><div class="ttdeci">Consumer()</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_message_html"><div class="ttname"><a href="classpulsar_1_1_message.html">pulsar::Message</a></div><div class="ttdef"><b>Definition</b> Message.h:44</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_message_id_html"><div class="ttname"><a href="classpulsar_1_1_message_id.html">pulsar::MessageId</a></div><div class="ttdef"><b>Definition</b> MessageId.h:34</div></div> |
| <div class="ttc" id="aclasspulsar_1_1_typed_message_html"><div class="ttname"><a href="classpulsar_1_1_typed_message.html">pulsar::TypedMessage</a></div><div class="ttdef"><b>Definition</b> TypedMessage.h:28</div></div> |
| <div class="ttc" id="anamespacepulsar_html"><div class="ttname"><a href="namespacepulsar.html">pulsar</a></div><div class="ttdef"><b>Definition</b> Authentication.h:31</div></div> |
| <div class="ttc" id="anamespacepulsar_html_ac87806090d752fb2248e8da65727630a"><div class="ttname"><a href="namespacepulsar.html#ac87806090d752fb2248e8da65727630a">pulsar::Messages</a></div><div class="ttdeci">std::vector< Message > Messages</div><div class="ttdoc">Callback definition for non-data operation.</div><div class="ttdef"><b>Definition</b> ConsumerConfiguration.h:49</div></div> |
| <div class="ttc" id="anamespacepulsar_html_ae5bf6401bfa8e3962e5c8f9fa2efbf4d"><div class="ttname"><a href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">pulsar::ResultCallback</a></div><div class="ttdeci">std::function< void(Result result)> ResultCallback</div><div class="ttdoc">Callback definition for non-data operation.</div><div class="ttdef"><b>Definition</b> ConsumerConfiguration.h:50</div></div> |
| <div class="ttc" id="anamespacepulsar_html_ae85314d6b9e8afd831cf8c66705f2dbb"><div class="ttname"><a href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">pulsar::Result</a></div><div class="ttdeci">Result</div><div class="ttdef"><b>Definition</b> Result.h:32</div></div> |
| </div><!-- fragment --></div><!-- contents --> |
| <!-- start footer part --> |
| <hr class="footer"/><address class="footer"><small> |
| Generated by <a href="https://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.7 |
| </small></address> |
| </body> |
| </html> |
