| <!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.12.0"/> |
| <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> |
| <script type="text/javascript" src="clipboard.js"></script> |
| <link href="navtree.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="resize.js"></script> |
| <script type="text/javascript" src="cookie.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.12.0 --> |
| <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"> |
| /* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&dn=expat.txt MIT */ |
| $(function() { codefold.init(0); }); |
| /* @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',false); |
| $(function() { init_search(); }); |
| }); |
| /* @license-end */ |
| </script> |
| <div id="main-nav"></div> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&dn=expat.txt MIT */ |
| $(function(){ initResizable(false); }); |
| /* @license-end */ |
| </script> |
| <!-- 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 id="doc-content"> |
| <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="foldopen" id="foldopen00037" data-start="{" data-end="};"> |
| <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="l00058" name="l00058"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a83f58a6118a693398c16e70cecac0303"> 58</a></span> <span class="keyword">const</span> std::string& <a class="code hl_function" href="classpulsar_1_1_consumer.html#a83f58a6118a693398c16e70cecac0303">getConsumerName</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a id="l00059" name="l00059"></a><span class="lineno"> 59</span> </div> |
| <div class="line"><a id="l00073" name="l00073"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a542ca0a9473a03ccf8bd8aeed24de490"> 73</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="l00074" name="l00074"></a><span class="lineno"> 74</span> </div> |
| <div class="line"><a id="l00086" name="l00086"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a8691920cae838418f33f13690a72771d"> 86</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="l00087" name="l00087"></a><span class="lineno"> 87</span> </div> |
| <div class="line"><a id="l00098" name="l00098"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#abc8cec6e81c582c6af8e3d931e41a2ad"> 98</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="l00099" name="l00099"></a><span class="lineno"> 99</span> </div> |
| <div class="line"><a id="l00100" name="l00100"></a><span class="lineno"> 100</span> <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a id="l00101" name="l00101"></a><span class="lineno"> 101</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="l00102" name="l00102"></a><span class="lineno"> 102</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a> rawMsg;</div> |
| <div class="line"><a id="l00103" name="l00103"></a><span class="lineno"> 103</span> <span class="keyword">auto</span> result = receive(rawMsg);</div> |
| <div class="line"><a id="l00104" name="l00104"></a><span class="lineno"> 104</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="l00105" name="l00105"></a><span class="lineno"> 105</span> <span class="keywordflow">return</span> result;</div> |
| <div class="line"><a id="l00106" name="l00106"></a><span class="lineno"> 106</span> }</div> |
| <div class="line"><a id="l00107" name="l00107"></a><span class="lineno"> 107</span> </div> |
| <div class="line"><a id="l00116" name="l00116"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ace9475b70f37c91df5b442f41058370e"> 116</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="l00117" name="l00117"></a><span class="lineno"> 117</span> </div> |
| <div class="line"><a id="l00118" name="l00118"></a><span class="lineno"> 118</span> <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a id="l00119" name="l00119"></a><span class="lineno"> 119</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="l00120" name="l00120"></a><span class="lineno"> 120</span> <a class="code hl_class" href="classpulsar_1_1_message.html">Message</a> rawMsg;</div> |
| <div class="line"><a id="l00121" name="l00121"></a><span class="lineno"> 121</span> <span class="keyword">auto</span> result = receive(rawMsg, timeoutMs);</div> |
| <div class="line"><a id="l00122" name="l00122"></a><span class="lineno"> 122</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="l00123" name="l00123"></a><span class="lineno"> 123</span> <span class="keywordflow">return</span> result;</div> |
| <div class="line"><a id="l00124" name="l00124"></a><span class="lineno"> 124</span> }</div> |
| <div class="line"><a id="l00125" name="l00125"></a><span class="lineno"> 125</span> </div> |
| <div class="line"><a id="l00137" name="l00137"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a0189416fb8672b23919276cc9f1bba5d"> 137</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="l00138" name="l00138"></a><span class="lineno"> 138</span> </div> |
| <div class="line"><a id="l00139" name="l00139"></a><span class="lineno"> 139</span> <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a id="l00140" name="l00140"></a><span class="lineno"> 140</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="l00141" name="l00141"></a><span class="lineno"> 141</span> <span class="keyword">typename</span> TypedMessage<T>::Decoder decoder) {</div> |
| <div class="line"><a id="l00142" name="l00142"></a><span class="lineno"> 142</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="l00143" name="l00143"></a><span class="lineno"> 143</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="l00144" name="l00144"></a><span class="lineno"> 144</span> });</div> |
| <div class="line"><a id="l00145" name="l00145"></a><span class="lineno"> 145</span> }</div> |
| <div class="line"><a id="l00146" name="l00146"></a><span class="lineno"> 146</span> </div> |
| <div class="line"><a id="l00157" name="l00157"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a49c846a386d778df94a1439982be5cbd"> 157</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="l00158" name="l00158"></a><span class="lineno"> 158</span> </div> |
| <div class="line"><a id="l00170" name="l00170"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ac403fe5941453dcfc41cc01055bca16e"> 170</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="l00171" name="l00171"></a><span class="lineno"> 171</span> </div> |
| <div class="line"><a id="l00183" name="l00183"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3c3eb5056f228d281798f9ea75f52af9"> 183</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="l00184" name="l00184"></a><span class="lineno"> 184</span> </div> |
| <div class="line"><a id="l00195" name="l00195"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#aed10e043835e50d8129e6adecd91da72"> 195</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="l00196" name="l00196"></a><span class="lineno"> 196</span> </div> |
| <div class="line"><a id="l00201" name="l00201"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a57fd2c53a44ea53262742d90ff11e0fd"> 201</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="l00202" name="l00202"></a><span class="lineno"> 202</span> </div> |
| <div class="line"><a id="l00212" name="l00212"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a867bebab981d5aa2f74217308aa2353c"> 212</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="l00213" name="l00213"></a><span class="lineno"> 213</span> </div> |
| <div class="line"><a id="l00223" name="l00223"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3a08b7cdcc9a1733ce7066173bfcdc28"> 223</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="l00224" name="l00224"></a><span class="lineno"> 224</span> </div> |
| <div class="line"><a id="l00231" name="l00231"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a74283a098beeb002e15a1dbba9fcff13"> 231</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="l00232" name="l00232"></a><span class="lineno"> 232</span> </div> |
| <div class="line"><a id="l00250" name="l00250"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3eb0b0db2da0628da15d3f242e254f6d"> 250</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="l00251" name="l00251"></a><span class="lineno"> 251</span> </div> |
| <div class="line"><a id="l00268" name="l00268"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a79558de7435fd0b6ca0bde84f3061822"> 268</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="l00269" name="l00269"></a><span class="lineno"> 269</span> </div> |
| <div class="line"><a id="l00280" name="l00280"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a6ad164b1ab4449b17bce764224e92960"> 280</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="l00281" name="l00281"></a><span class="lineno"> 281</span> </div> |
| <div class="line"><a id="l00292" name="l00292"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a5d4cf148f372618961fd3411792a5cd7"> 292</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="l00293" name="l00293"></a><span class="lineno"> 293</span> </div> |
| <div class="line"><a id="l00324" name="l00324"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3cd227d9be2ae090c3a55bcdfff1df69"> 324</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="l00325" name="l00325"></a><span class="lineno"> 325</span> </div> |
| <div class="line"><a id="l00356" name="l00356"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#afd631d1c357bc0284afe3e0cd2acbd6e"> 356</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="l00357" name="l00357"></a><span class="lineno"> 357</span> </div> |
| <div class="line"><a id="l00361" name="l00361"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a8b01803221c283e4df21715aeb024b84"> 361</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="l00362" name="l00362"></a><span class="lineno"> 362</span> </div> |
| <div class="line"><a id="l00367" name="l00367"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a1b4539f46eb42170a550d6cd9076d8d7"> 367</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="l00368" name="l00368"></a><span class="lineno"> 368</span> </div> |
| <div class="line"><a id="l00372" name="l00372"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a7370b7a19a08fdff5b044e74ad8bd679"> 372</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="l00373" name="l00373"></a><span class="lineno"> 373</span> </div> |
| <div class="line"><a id="l00378" name="l00378"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a02a9a412f1aa7f1ec8dc0c0134315b66"> 378</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="l00379" name="l00379"></a><span class="lineno"> 379</span> </div> |
| <div class="line"><a id="l00389" name="l00389"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a3d60ee12b0e9766d60c3a8e08a61287a"> 389</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="l00390" name="l00390"></a><span class="lineno"> 390</span> </div> |
| <div class="line"><a id="l00403" name="l00403"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a617639e11e05ecba3d013d831578d19d"> 403</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="l00404" name="l00404"></a><span class="lineno"> 404</span> </div> |
| <div class="line"><a id="l00416" name="l00416"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a01e55f7906b6922fa069d84f5459af4b"> 416</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="l00417" name="l00417"></a><span class="lineno"> 417</span> </div> |
| <div class="line"><a id="l00428" name="l00428"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a45800c18df817caabe6cd9c21e7d72b3"> 428</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="l00429" name="l00429"></a><span class="lineno"> 429</span> </div> |
| <div class="line"><a id="l00436" name="l00436"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#ae6835e612b61795a13eff5fd2da85a0e"> 436</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="l00437" name="l00437"></a><span class="lineno"> 437</span> </div> |
| <div class="line"><a id="l00448" name="l00448"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#af1c892616483868ce5e30be46e7a40bf"> 448</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="l00449" name="l00449"></a><span class="lineno"> 449</span> </div> |
| <div class="line"><a id="l00456" name="l00456"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a01761bcf98436600d5f4d461582db94f"> 456</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="l00457" name="l00457"></a><span class="lineno"> 457</span> </div> |
| <div class="line"><a id="l00461" name="l00461"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#a95a69d39ec2c8714b6ffce0f6ab74a55"> 461</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="l00462" name="l00462"></a><span class="lineno"> 462</span> </div> |
| <div class="line"><a id="l00467" name="l00467"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#afbd9e4f5b33b5b10a32866d3485cbeb5"> 467</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="l00468" name="l00468"></a><span class="lineno"> 468</span> </div> |
| <div class="line"><a id="l00472" name="l00472"></a><span class="lineno"><a class="line" href="classpulsar_1_1_consumer.html#af60a7e87b76e5c69ee0e14f6ec902908"> 472</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="l00473" name="l00473"></a><span class="lineno"> 473</span> </div> |
| <div class="line"><a id="l00474" name="l00474"></a><span class="lineno"> 474</span> <span class="keyword">private</span>:</div> |
| <div class="line"><a id="l00475" name="l00475"></a><span class="lineno"> 475</span> ConsumerImplBasePtr impl_;</div> |
| <div class="line"><a id="l00476" name="l00476"></a><span class="lineno"> 476</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="l00477" name="l00477"></a><span class="lineno"> 477</span> </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>PulsarFriend;</div> |
| <div class="line"><a id="l00479" name="l00479"></a><span class="lineno"> 479</span> <span class="keyword">friend</span> <span class="keyword">class </span>PulsarWrapper;</div> |
| <div class="line"><a id="l00480" name="l00480"></a><span class="lineno"> 480</span> <span class="keyword">friend</span> <span class="keyword">class </span>MultiTopicsConsumerImpl;</div> |
| <div class="line"><a id="l00481" name="l00481"></a><span class="lineno"> 481</span> <span class="keyword">friend</span> <span class="keyword">class </span>ConsumerImpl;</div> |
| <div class="line"><a id="l00482" name="l00482"></a><span class="lineno"> 482</span> <span class="keyword">friend</span> <span class="keyword">class </span>ClientImpl;</div> |
| <div class="line"><a id="l00483" name="l00483"></a><span class="lineno"> 483</span> <span class="keyword">friend</span> <span class="keyword">class </span>ConsumerTest;</div> |
| <div class="line"><a id="l00484" name="l00484"></a><span class="lineno"> 484</span>};</div> |
| </div> |
| <div class="line"><a id="l00485" name="l00485"></a><span class="lineno"> 485</span>} <span class="comment">// namespace pulsar</span></div> |
| <div class="line"><a id="l00486" name="l00486"></a><span class="lineno"> 486</span> </div> |
| <div class="line"><a id="l00487" name="l00487"></a><span class="lineno"> 487</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_a83f58a6118a693398c16e70cecac0303"><div class="ttname"><a href="classpulsar_1_1_consumer.html#a83f58a6118a693398c16e70cecac0303">pulsar::Consumer::getConsumerName</a></div><div class="ttdeci">const std::string & getConsumerName() const</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.12.0 |
| </small></address> |
| </div><!-- doc-content --> |
| </body> |
| </html> |
