| <!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.15.0"/> |
| <meta name="viewport" content="width=device-width, initial-scale=1"/> |
| <title>pulsar-client-cpp: pulsar::Reader Class Reference</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> |
| <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.15.0 --> |
| <script type="text/javascript"> |
| var searchBox = new SearchBox("searchBox", "search/",'.html'); |
| </script> |
| <script type="text/javascript"> |
| $(function() { codefold.init(); }); |
| </script> |
| <script type="text/javascript" src="menudata.js"></script> |
| <script type="text/javascript" src="menu.js"></script> |
| <script type="text/javascript"> |
| $(function() { |
| initMenu('',true,false,'search.php','Search',false); |
| $(function() { init_search(); }); |
| }); |
| </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 href="namespacepulsar.html">pulsar</a></li><li class="navelem"><a href="classpulsar_1_1_reader.html">Reader</a></li> </ul> |
| </div> |
| </div><!-- top --> |
| <div id="doc-content"> |
| <div class="header"> |
| <div class="summary"> |
| <a href="#pub-methods">Public Member Functions</a> | |
| <a href="#friends">Friends</a> | |
| <a href="classpulsar_1_1_reader-members.html">List of all members</a> </div> |
| <div class="headertitle"><div class="title">pulsar::Reader Class Reference</div></div> |
| </div><!--header--> |
| <div class="contents"> |
| |
| <p><code>#include <<a class="el" href="_reader_8h_source.html">Reader.h</a>></code></p> |
| <table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 id="header-pub-methods" class="groupheader"><a id="pub-methods" name="pub-methods"></a> |
| Public Member Functions</h2></td></tr> |
| <tr class="memitem:a1c34e49ba3dbca0ff7e23ea9ff94db7b" id="r_a1c34e49ba3dbca0ff7e23ea9ff94db7b"><td class="memItemLeft" align="right" valign="top"> </td><td class="memItemRight" valign="bottom"><a class="el" href="#a1c34e49ba3dbca0ff7e23ea9ff94db7b">Reader</a> ()</td></tr> |
| <tr class="memitem:a1b682c6bacd8514221bbb6b25c84c051" id="r_a1b682c6bacd8514221bbb6b25c84c051"><td class="memItemLeft" align="right" valign="top">const std::string & </td><td class="memItemRight" valign="bottom"><a class="el" href="#a1b682c6bacd8514221bbb6b25c84c051">getTopic</a> () const</td></tr> |
| <tr class="memitem:a11756c69a2f5bd99e302a384ae8a9ff4" id="r_a11756c69a2f5bd99e302a384ae8a9ff4"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="#a11756c69a2f5bd99e302a384ae8a9ff4">readNext</a> (<a class="el" href="classpulsar_1_1_message.html">Message</a> &msg)</td></tr> |
| <tr class="memitem:a39c664ea68774721bc0e772b38449b22" id="r_a39c664ea68774721bc0e772b38449b22"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="#a39c664ea68774721bc0e772b38449b22">readNext</a> (<a class="el" href="classpulsar_1_1_message.html">Message</a> &msg, int timeoutMs)</td></tr> |
| <tr class="memitem:a40ea70f3ba7c44ef26a812cf903acd6f" id="r_a40ea70f3ba7c44ef26a812cf903acd6f"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="#a40ea70f3ba7c44ef26a812cf903acd6f">readNextAsync</a> (const ReadNextCallback &callback)</td></tr> |
| <tr class="memitem:ab15cfd0e35d625d2f1af5936c314b623" id="r_ab15cfd0e35d625d2f1af5936c314b623"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="#ab15cfd0e35d625d2f1af5936c314b623">close</a> ()</td></tr> |
| <tr class="memitem:ab234ee3213e8c956cf987f1d3592a35f" id="r_ab234ee3213e8c956cf987f1d3592a35f"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="#ab234ee3213e8c956cf987f1d3592a35f">closeAsync</a> (const <a class="el" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> &callback)</td></tr> |
| <tr class="memitem:a97b4bcd925cc6c3ec7c1b756ad69298b" id="r_a97b4bcd925cc6c3ec7c1b756ad69298b"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="#a97b4bcd925cc6c3ec7c1b756ad69298b">hasMessageAvailableAsync</a> (const HasMessageAvailableCallback &callback)</td></tr> |
| <tr class="memitem:a7f751b63fba4d4734ff79da590f9fd56" id="r_a7f751b63fba4d4734ff79da590f9fd56"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="#a7f751b63fba4d4734ff79da590f9fd56">hasMessageAvailable</a> (bool &hasMessageAvailable)</td></tr> |
| <tr class="memitem:a6bec25700e5b4eb7be41625a9bc856bd" id="r_a6bec25700e5b4eb7be41625a9bc856bd"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="#a6bec25700e5b4eb7be41625a9bc856bd">seek</a> (const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &msgId)</td></tr> |
| <tr class="memitem:adebdd61a5150777704c8ce8dcec08fc8" id="r_adebdd61a5150777704c8ce8dcec08fc8"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="#adebdd61a5150777704c8ce8dcec08fc8">seek</a> (uint64_t timestamp)</td></tr> |
| <tr class="memitem:ab9382fcb52cb2d69c1f744c127b6e1a5" id="r_ab9382fcb52cb2d69c1f744c127b6e1a5"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="#ab9382fcb52cb2d69c1f744c127b6e1a5">seekAsync</a> (const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &msgId, const <a class="el" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> &callback)</td></tr> |
| <tr class="memitem:a3019e6f349af33c8d4611a327e265b8c" id="r_a3019e6f349af33c8d4611a327e265b8c"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="#a3019e6f349af33c8d4611a327e265b8c">seekAsync</a> (uint64_t timestamp, const <a class="el" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> &callback)</td></tr> |
| <tr class="memitem:a9eda13274f7b1f880694fc1178ae631d" id="r_a9eda13274f7b1f880694fc1178ae631d"><td class="memItemLeft" align="right" valign="top">bool </td><td class="memItemRight" valign="bottom"><a class="el" href="#a9eda13274f7b1f880694fc1178ae631d">isConnected</a> () const</td></tr> |
| <tr class="memitem:a2be8d6367b5af38ddb91020f2a46d202" id="r_a2be8d6367b5af38ddb91020f2a46d202"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="#a2be8d6367b5af38ddb91020f2a46d202">getLastMessageIdAsync</a> (const GetLastMessageIdCallback &callback)</td></tr> |
| <tr class="memitem:a80a0a4dbbe3cf8a9fb074c7556715823" id="r_a80a0a4dbbe3cf8a9fb074c7556715823"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="#a80a0a4dbbe3cf8a9fb074c7556715823">getLastMessageId</a> (<a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &messageId)</td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 id="header-friends" class="groupheader"><a id="friends" name="friends"></a> |
| Friends</h2></td></tr> |
| <tr class="memitem:ac1899b25eaceed54fad39b7b44d8a00f" id="r_ac1899b25eaceed54fad39b7b44d8a00f"><td class="memItemLeft" align="right" valign="top"><a id="ac1899b25eaceed54fad39b7b44d8a00f" name="ac1899b25eaceed54fad39b7b44d8a00f"></a> |
| class </td><td class="memItemRight" valign="bottom"><b>PulsarFriend</b></td></tr> |
| <tr class="memitem:aec24ec969dcf4df0185304ccbf6d653c" id="r_aec24ec969dcf4df0185304ccbf6d653c"><td class="memItemLeft" align="right" valign="top"><a id="aec24ec969dcf4df0185304ccbf6d653c" name="aec24ec969dcf4df0185304ccbf6d653c"></a> |
| class </td><td class="memItemRight" valign="bottom"><b>PulsarWrapper</b></td></tr> |
| <tr class="memitem:ad487408ba3f9484aa0f890458286d71d" id="r_ad487408ba3f9484aa0f890458286d71d"><td class="memItemLeft" align="right" valign="top"><a id="ad487408ba3f9484aa0f890458286d71d" name="ad487408ba3f9484aa0f890458286d71d"></a> |
| class </td><td class="memItemRight" valign="bottom"><b>ReaderImpl</b></td></tr> |
| <tr class="memitem:a1854aa6ea210fd235b7165e67178645b" id="r_a1854aa6ea210fd235b7165e67178645b"><td class="memItemLeft" align="right" valign="top"><a id="a1854aa6ea210fd235b7165e67178645b" name="a1854aa6ea210fd235b7165e67178645b"></a> |
| class </td><td class="memItemRight" valign="bottom"><b>TableViewImpl</b></td></tr> |
| <tr class="memitem:ab4fd26c01391d0e9642830b3f3442e0c" id="r_ab4fd26c01391d0e9642830b3f3442e0c"><td class="memItemLeft" align="right" valign="top"><a id="ab4fd26c01391d0e9642830b3f3442e0c" name="ab4fd26c01391d0e9642830b3f3442e0c"></a> |
| class </td><td class="memItemRight" valign="bottom"><b>ReaderTest</b></td></tr> |
| </table> |
| <a name="details" id="details"></a><h2 id="header-details" class="groupheader">Detailed Description</h2> |
| <div class="textblock"><p>A <a class="el" href="classpulsar_1_1_reader.html">Reader</a> can be used to scan through all the messages currently available in a topic. </p> |
| </div><a name="doc-constructors" id="doc-constructors"></a><h2 id="header-doc-constructors" class="groupheader">Constructor & Destructor Documentation</h2> |
| <a id="a1c34e49ba3dbca0ff7e23ea9ff94db7b" name="a1c34e49ba3dbca0ff7e23ea9ff94db7b"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a1c34e49ba3dbca0ff7e23ea9ff94db7b">◆ </a></span>Reader()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">pulsar::Reader::Reader </td> |
| <td>(</td> |
| <td class="paramname"><span class="paramname"><em></em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Construct an uninitialized reader object </p> |
| |
| </div> |
| </div> |
| <a name="doc-func-members" id="doc-func-members"></a><h2 id="header-doc-func-members" class="groupheader">Member Function Documentation</h2> |
| <a id="ab15cfd0e35d625d2f1af5936c314b623" name="ab15cfd0e35d625d2f1af5936c314b623"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ab15cfd0e35d625d2f1af5936c314b623">◆ </a></span>close()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> pulsar::Reader::close </td> |
| <td>(</td> |
| <td class="paramname"><span class="paramname"><em></em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Close the reader and stop the broker to push more messages</p> |
| <dl class="section return"><dt>Returns</dt><dd>ResultOk if the reader is closed successfully </dd></dl> |
| |
| </div> |
| </div> |
| <a id="ab234ee3213e8c956cf987f1d3592a35f" name="ab234ee3213e8c956cf987f1d3592a35f"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ab234ee3213e8c956cf987f1d3592a35f">◆ </a></span>closeAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Reader::closeAsync </td> |
| <td>(</td> |
| <td class="paramtype">const <a class="el" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> &</td> <td class="paramname"><span class="paramname"><em>callback</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously close the reader and stop the broker to push more messages</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">callback</td><td>the callback that is triggered when the reader is closed </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a80a0a4dbbe3cf8a9fb074c7556715823" name="a80a0a4dbbe3cf8a9fb074c7556715823"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a80a0a4dbbe3cf8a9fb074c7556715823">◆ </a></span>getLastMessageId()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> pulsar::Reader::getLastMessageId </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &</td> <td class="paramname"><span class="paramname"><em>messageId</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Get an ID of the last available message or a message ID with -1 as an entryId if the topic is empty. </p> |
| |
| </div> |
| </div> |
| <a id="a2be8d6367b5af38ddb91020f2a46d202" name="a2be8d6367b5af38ddb91020f2a46d202"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a2be8d6367b5af38ddb91020f2a46d202">◆ </a></span>getLastMessageIdAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Reader::getLastMessageIdAsync </td> |
| <td>(</td> |
| <td class="paramtype">const GetLastMessageIdCallback &</td> <td class="paramname"><span class="paramname"><em>callback</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously get an ID of the last available message or a message ID with -1 as an entryId if the topic is empty. </p> |
| |
| </div> |
| </div> |
| <a id="a1b682c6bacd8514221bbb6b25c84c051" name="a1b682c6bacd8514221bbb6b25c84c051"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a1b682c6bacd8514221bbb6b25c84c051">◆ </a></span>getTopic()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">const std::string & pulsar::Reader::getTopic </td> |
| <td>(</td> |
| <td class="paramname"><span class="paramname"><em></em></span></td><td>)</td> |
| <td> const</td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <dl class="section return"><dt>Returns</dt><dd>the topic this reader is reading from </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a7f751b63fba4d4734ff79da590f9fd56" name="a7f751b63fba4d4734ff79da590f9fd56"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a7f751b63fba4d4734ff79da590f9fd56">◆ </a></span>hasMessageAvailable()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> pulsar::Reader::hasMessageAvailable </td> |
| <td>(</td> |
| <td class="paramtype">bool &</td> <td class="paramname"><span class="paramname"><em>hasMessageAvailable</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Check if there is any message available to read from the current position. </p> |
| |
| </div> |
| </div> |
| <a id="a97b4bcd925cc6c3ec7c1b756ad69298b" name="a97b4bcd925cc6c3ec7c1b756ad69298b"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a97b4bcd925cc6c3ec7c1b756ad69298b">◆ </a></span>hasMessageAvailableAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Reader::hasMessageAvailableAsync </td> |
| <td>(</td> |
| <td class="paramtype">const HasMessageAvailableCallback &</td> <td class="paramname"><span class="paramname"><em>callback</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously check if there is any message available to read from the current position. </p> |
| |
| </div> |
| </div> |
| <a id="a9eda13274f7b1f880694fc1178ae631d" name="a9eda13274f7b1f880694fc1178ae631d"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a9eda13274f7b1f880694fc1178ae631d">◆ </a></span>isConnected()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">bool pulsar::Reader::isConnected </td> |
| <td>(</td> |
| <td class="paramname"><span class="paramname"><em></em></span></td><td>)</td> |
| <td> const</td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <dl class="section return"><dt>Returns</dt><dd>Whether the reader is currently connected to the broker </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a11756c69a2f5bd99e302a384ae8a9ff4" name="a11756c69a2f5bd99e302a384ae8a9ff4"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a11756c69a2f5bd99e302a384ae8a9ff4">◆ </a></span>readNext() <span class="overload">[1/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> pulsar::Reader::readNext </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_message.html">Message</a> &</td> <td class="paramname"><span class="paramname"><em>msg</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Read a single message.</p> |
| <p>If a message is not immediately available, this method will block until a new message is available.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">msg</td><td>a non-const reference where the received message will be copied </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>ResultOk when a message is received </dd> |
| <dd> |
| ResultInvalidConfiguration if a message listener had been set in the configuration </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a39c664ea68774721bc0e772b38449b22" name="a39c664ea68774721bc0e772b38449b22"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a39c664ea68774721bc0e772b38449b22">◆ </a></span>readNext() <span class="overload">[2/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> pulsar::Reader::readNext </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_message.html">Message</a> &</td> <td class="paramname"><span class="paramname"><em>msg</em></span>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">int</td> <td class="paramname"><span class="paramname"><em>timeoutMs</em></span> )</td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Read a single message</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">msg</td><td>a non-const reference where the received message will be copied </td></tr> |
| <tr><td class="paramname">timeoutMs</td><td>the receive timeout in milliseconds </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>ResultOk if a message was received </dd> |
| <dd> |
| ResultTimeout if the receive timeout was triggered </dd> |
| <dd> |
| ResultInvalidConfiguration if a message listener had been set in the configuration </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a40ea70f3ba7c44ef26a812cf903acd6f" name="a40ea70f3ba7c44ef26a812cf903acd6f"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a40ea70f3ba7c44ef26a812cf903acd6f">◆ </a></span>readNextAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Reader::readNextAsync </td> |
| <td>(</td> |
| <td class="paramtype">const ReadNextCallback &</td> <td class="paramname"><span class="paramname"><em>callback</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Read asynchronously the next message in the topic.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">callback</td><td></td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a6bec25700e5b4eb7be41625a9bc856bd" name="a6bec25700e5b4eb7be41625a9bc856bd"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a6bec25700e5b4eb7be41625a9bc856bd">◆ </a></span>seek() <span class="overload">[1/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> pulsar::Reader::seek </td> |
| <td>(</td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &</td> <td class="paramname"><span class="paramname"><em>msgId</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Reset the this reader to a specific message id. The message id can either be a specific message or represent the first or last messages in the topic.</p> |
| <p>Note: this operation can only be done on non-partitioned topics. For these, one can rather perform the <a class="el" href="#a6bec25700e5b4eb7be41625a9bc856bd">seek()</a> on the individual partitions.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">messageId</td><td>the message id where to reposition the subscription </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="adebdd61a5150777704c8ce8dcec08fc8" name="adebdd61a5150777704c8ce8dcec08fc8"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#adebdd61a5150777704c8ce8dcec08fc8">◆ </a></span>seek() <span class="overload">[2/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#a23832680be30b95d54755b56310e9079">Result</a> pulsar::Reader::seek </td> |
| <td>(</td> |
| <td class="paramtype">uint64_t</td> <td class="paramname"><span class="paramname"><em>timestamp</em></span></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Reset this reader to a specific message publish time.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">timestamp</td><td>the message publish time where to reposition the subscription </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="ab9382fcb52cb2d69c1f744c127b6e1a5" name="ab9382fcb52cb2d69c1f744c127b6e1a5"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ab9382fcb52cb2d69c1f744c127b6e1a5">◆ </a></span>seekAsync() <span class="overload">[1/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Reader::seekAsync </td> |
| <td>(</td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &</td> <td class="paramname"><span class="paramname"><em>msgId</em></span>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> &</td> <td class="paramname"><span class="paramname"><em>callback</em></span> )</td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously reset this reader to a specific message id. The message id can either be a specific message or represent the first or last messages in the topic.</p> |
| <p>Note: this operation can only be done on non-partitioned topics. For these, one can rather perform the <a class="el" href="#a6bec25700e5b4eb7be41625a9bc856bd">seek()</a> on the individual partitions.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">messageId</td><td>the message id where to reposition the subscription </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a3019e6f349af33c8d4611a327e265b8c" name="a3019e6f349af33c8d4611a327e265b8c"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a3019e6f349af33c8d4611a327e265b8c">◆ </a></span>seekAsync() <span class="overload">[2/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Reader::seekAsync </td> |
| <td>(</td> |
| <td class="paramtype">uint64_t</td> <td class="paramname"><span class="paramname"><em>timestamp</em></span>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="namespacepulsar.html#ae5bf6401bfa8e3962e5c8f9fa2efbf4d">ResultCallback</a> &</td> <td class="paramname"><span class="paramname"><em>callback</em></span> )</td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously reset this reader to a specific message publish time.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">timestamp</td><td>the message publish time where to reposition the subscription </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <hr/>The documentation for this class was generated from the following file:<ul> |
| <li>include/pulsar/<a class="el" href="_reader_8h_source.html">Reader.h</a></li> |
| </ul> |
| </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.15.0 |
| </small></address> |
| </div><!-- doc-content --> |
| </body> |
| </html> |
