| <!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.5"/> |
| <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.5 --> |
| <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 <iostream></span></div> |
| <div class="line"><a id="l00023" name="l00023"></a><span class="lineno"> 23</span><span class="preprocessor">#include <pulsar/defines.h></span></div> |
| <div class="line"><a id="l00024" name="l00024"></a><span class="lineno"> 24</span><span class="preprocessor">#include <pulsar/BrokerConsumerStats.h></span></div> |
| <div class="line"><a id="l00025" name="l00025"></a><span class="lineno"> 25</span><span class="preprocessor">#include <pulsar/ConsumerConfiguration.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="keyword">namespace </span><a class="code hl_namespace" href="namespacepulsar.html">pulsar</a> {</div> |
| <div class="line"><a id="l00028" name="l00028"></a><span class="lineno"> 28</span><span class="keyword">class </span>PulsarWrapper;</div> |
| <div class="line"><a id="l00029" name="l00029"></a><span class="lineno"> 29</span><span class="keyword">class </span>ConsumerImplBase;</div> |
| <div class="line"><a id="l00030" name="l00030"></a><span class="lineno"> 30</span><span class="keyword">class </span>PulsarFriend;</div> |
| <div class="line"><a id="l00031" name="l00031"></a><span class="lineno"> 31</span><span class="keyword">typedef</span> std::shared_ptr<ConsumerImplBase> ConsumerImplBasePtr;</div> |
| <div class="line"><a id="l00035" name="l00035"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html"> 35</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="l00036" name="l00036"></a><span class="lineno"> 36</span> <span class="keyword">public</span>:</div> |
| <div class="line"><a id="l00040" name="l00040"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#afe59503d5d5309f38d4e246bd9f435b4"> 40</a></span> <a class="code hl_function" href="classpulsar_1_1_consumer.html#afe59503d5d5309f38d4e246bd9f435b4">Consumer</a>();</div> |
| <div class="line"><a id="l00041" name="l00041"></a><span class="lineno"> 41</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="l00042" name="l00042"></a><span class="lineno"> 42</span> </div> |
| <div class="line"><a id="l00046" name="l00046"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ad55d95cd75501562d8ae6d83935d5977"> 46</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="l00047" name="l00047"></a><span class="lineno"> 47</span> </div> |
| <div class="line"><a id="l00051" name="l00051"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#af6049caaf3e1f8bc91d4dc52b02ab7d1"> 51</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="l00052" name="l00052"></a><span class="lineno"> 52</span> </div> |
| <div class="line"><a id="l00066" name="l00066"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a542ca0a9473a03ccf8bd8aeed24de490"> 66</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="l00067" name="l00067"></a><span class="lineno"> 67</span> </div> |
| <div class="line"><a id="l00079" name="l00079"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a8691920cae838418f33f13690a72771d"> 79</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="l00080" name="l00080"></a><span class="lineno"> 80</span> </div> |
| <div class="line"><a id="l00091" name="l00091"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#abc8cec6e81c582c6af8e3d931e41a2ad"> 91</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="l00092" name="l00092"></a><span class="lineno"> 92</span> </div> |
| <div class="line"><a id="l00101" name="l00101"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ace9475b70f37c91df5b442f41058370e"> 101</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="l00102" name="l00102"></a><span class="lineno"> 102</span> </div> |
| <div class="line"><a id="l00114" name="l00114"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a0189416fb8672b23919276cc9f1bba5d"> 114</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="l00115" name="l00115"></a><span class="lineno"> 115</span> </div> |
| <div class="line"><a id="l00127" name="l00127"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3c3eb5056f228d281798f9ea75f52af9"> 127</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="l00128" name="l00128"></a><span class="lineno"> 128</span> </div> |
| <div class="line"><a id="l00139" name="l00139"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#aed10e043835e50d8129e6adecd91da72"> 139</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="l00140" name="l00140"></a><span class="lineno"> 140</span> </div> |
| <div class="line"><a id="l00150" name="l00150"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a867bebab981d5aa2f74217308aa2353c"> 150</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="l00151" name="l00151"></a><span class="lineno"> 151</span> </div> |
| <div class="line"><a id="l00161" name="l00161"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3a08b7cdcc9a1733ce7066173bfcdc28"> 161</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="l00162" name="l00162"></a><span class="lineno"> 162</span> </div> |
| <div class="line"><a id="l00180" name="l00180"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3eb0b0db2da0628da15d3f242e254f6d"> 180</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="l00181" name="l00181"></a><span class="lineno"> 181</span> </div> |
| <div class="line"><a id="l00198" name="l00198"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a79558de7435fd0b6ca0bde84f3061822"> 198</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="l00199" name="l00199"></a><span class="lineno"> 199</span> </div> |
| <div class="line"><a id="l00210" name="l00210"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a6ad164b1ab4449b17bce764224e92960"> 210</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="l00211" name="l00211"></a><span class="lineno"> 211</span> </div> |
| <div class="line"><a id="l00222" name="l00222"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a5d4cf148f372618961fd3411792a5cd7"> 222</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="l00223" name="l00223"></a><span class="lineno"> 223</span> </div> |
| <div class="line"><a id="l00254" name="l00254"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3cd227d9be2ae090c3a55bcdfff1df69"> 254</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="l00255" name="l00255"></a><span class="lineno"> 255</span> </div> |
| <div class="line"><a id="l00286" name="l00286"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#afd631d1c357bc0284afe3e0cd2acbd6e"> 286</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="l00287" name="l00287"></a><span class="lineno"> 287</span> </div> |
| <div class="line"><a id="l00291" name="l00291"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a8b01803221c283e4df21715aeb024b84"> 291</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="l00292" name="l00292"></a><span class="lineno"> 292</span> </div> |
| <div class="line"><a id="l00297" name="l00297"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a1b4539f46eb42170a550d6cd9076d8d7"> 297</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="l00298" name="l00298"></a><span class="lineno"> 298</span> </div> |
| <div class="line"><a id="l00302" name="l00302"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a7370b7a19a08fdff5b044e74ad8bd679"> 302</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="l00303" name="l00303"></a><span class="lineno"> 303</span> </div> |
| <div class="line"><a id="l00308" name="l00308"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a02a9a412f1aa7f1ec8dc0c0134315b66"> 308</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="l00309" name="l00309"></a><span class="lineno"> 309</span> </div> |
| <div class="line"><a id="l00319" name="l00319"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3d60ee12b0e9766d60c3a8e08a61287a"> 319</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="l00320" name="l00320"></a><span class="lineno"> 320</span> </div> |
| <div class="line"><a id="l00333" name="l00333"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a617639e11e05ecba3d013d831578d19d"> 333</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="l00334" name="l00334"></a><span class="lineno"> 334</span> </div> |
| <div class="line"><a id="l00346" name="l00346"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a01e55f7906b6922fa069d84f5459af4b"> 346</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="l00347" name="l00347"></a><span class="lineno"> 347</span> </div> |
| <div class="line"><a id="l00358" name="l00358"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a45800c18df817caabe6cd9c21e7d72b3"> 358</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="l00359" name="l00359"></a><span class="lineno"> 359</span> </div> |
| <div class="line"><a id="l00366" name="l00366"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ae6835e612b61795a13eff5fd2da85a0e"> 366</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="l00367" name="l00367"></a><span class="lineno"> 367</span> </div> |
| <div class="line"><a id="l00378" name="l00378"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#af1c892616483868ce5e30be46e7a40bf"> 378</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="l00379" name="l00379"></a><span class="lineno"> 379</span> </div> |
| <div class="line"><a id="l00386" name="l00386"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a01761bcf98436600d5f4d461582db94f"> 386</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="l00387" name="l00387"></a><span class="lineno"> 387</span> </div> |
| <div class="line"><a id="l00391" name="l00391"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a95a69d39ec2c8714b6ffce0f6ab74a55"> 391</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="l00392" name="l00392"></a><span class="lineno"> 392</span> </div> |
| <div class="line"><a id="l00393" name="l00393"></a><span class="lineno"> 393</span> <span class="keyword">private</span>:</div> |
| <div class="line"><a id="l00394" name="l00394"></a><span class="lineno"> 394</span> ConsumerImplBasePtr impl_;</div> |
| <div class="line"><a id="l00395" name="l00395"></a><span class="lineno"> 395</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="l00396" name="l00396"></a><span class="lineno"> 396</span> </div> |
| <div class="line"><a id="l00397" name="l00397"></a><span class="lineno"> 397</span> <span class="keyword">friend</span> <span class="keyword">class </span>PulsarFriend;</div> |
| <div class="line"><a id="l00398" name="l00398"></a><span class="lineno"> 398</span> <span class="keyword">friend</span> <span class="keyword">class </span>PulsarWrapper;</div> |
| <div class="line"><a id="l00399" name="l00399"></a><span class="lineno"> 399</span> <span class="keyword">friend</span> <span class="keyword">class </span>PartitionedConsumerImpl;</div> |
| <div class="line"><a id="l00400" name="l00400"></a><span class="lineno"> 400</span> <span class="keyword">friend</span> <span class="keyword">class </span>MultiTopicsConsumerImpl;</div> |
| <div class="line"><a id="l00401" name="l00401"></a><span class="lineno"> 401</span> <span class="keyword">friend</span> <span class="keyword">class </span>ConsumerImpl;</div> |
| <div class="line"><a id="l00402" name="l00402"></a><span class="lineno"> 402</span> <span class="keyword">friend</span> <span class="keyword">class </span>ClientImpl;</div> |
| <div class="line"><a id="l00403" name="l00403"></a><span class="lineno"> 403</span> <span class="keyword">friend</span> <span class="keyword">class </span>ConsumerTest;</div> |
| <div class="line"><a id="l00404" name="l00404"></a><span class="lineno"> 404</span>};</div> |
| <div class="line"><a id="l00405" name="l00405"></a><span class="lineno"> 405</span>} <span class="comment">// namespace pulsar</span></div> |
| <div class="line"><a id="l00406" name="l00406"></a><span class="lineno"> 406</span> </div> |
| <div class="line"><a id="l00407" name="l00407"></a><span class="lineno"> 407</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:35</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_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_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_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_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_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:42</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:32</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:30</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:40</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:31</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.5 |
| </small></address> |
| </body> |
| </html> |
