| <!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.8"/> |
| <meta name="viewport" content="width=device-width, initial-scale=1"/> |
| <title>pulsar-client-cpp: pulsar::Client 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> |
| <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.8 --> |
| <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="namespacepulsar.html">pulsar</a></li><li class="navelem"><a class="el" href="classpulsar_1_1_client.html">Client</a></li> </ul> |
| </div> |
| </div><!-- top --> |
| <div class="header"> |
| <div class="summary"> |
| <a href="#pub-methods">Public Member Functions</a> | |
| <a href="#friends">Friends</a> | |
| <a href="classpulsar_1_1_client-members.html">List of all members</a> </div> |
| <div class="headertitle"><div class="title">pulsar::Client Class Reference</div></div> |
| </div><!--header--> |
| <div class="contents"> |
| <table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a id="pub-methods" name="pub-methods"></a> |
| Public Member Functions</h2></td></tr> |
| <tr class="memitem:acab90af5d0542803bc1d10e68d27414f" id="r_acab90af5d0542803bc1d10e68d27414f"><td class="memItemLeft" align="right" valign="top"> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#acab90af5d0542803bc1d10e68d27414f">Client</a> (const std::string &serviceUrl)</td></tr> |
| <tr class="separator:acab90af5d0542803bc1d10e68d27414f"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a148122b14f22844d359c35c084907962" id="r_a148122b14f22844d359c35c084907962"><td class="memItemLeft" align="right" valign="top"> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a148122b14f22844d359c35c084907962">Client</a> (const std::string &serviceUrl, const <a class="el" href="classpulsar_1_1_client_configuration.html">ClientConfiguration</a> &clientConfiguration)</td></tr> |
| <tr class="separator:a148122b14f22844d359c35c084907962"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a96f49cc0ce27bfe68d75224991f0ba52" id="r_a96f49cc0ce27bfe68d75224991f0ba52"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a96f49cc0ce27bfe68d75224991f0ba52">createProducer</a> (const std::string &topic, <a class="el" href="classpulsar_1_1_producer.html">Producer</a> &producer)</td></tr> |
| <tr class="separator:a96f49cc0ce27bfe68d75224991f0ba52"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aae7658dee80ad23b418cfb7e12f5df05" id="r_aae7658dee80ad23b418cfb7e12f5df05"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#aae7658dee80ad23b418cfb7e12f5df05">createProducer</a> (const std::string &topic, const <a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a> &conf, <a class="el" href="classpulsar_1_1_producer.html">Producer</a> &producer)</td></tr> |
| <tr class="separator:aae7658dee80ad23b418cfb7e12f5df05"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a666be9ce0980aeda2921c2229c003db8" id="r_a666be9ce0980aeda2921c2229c003db8"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a666be9ce0980aeda2921c2229c003db8">createProducerAsync</a> (const std::string &topic, CreateProducerCallback callback)</td></tr> |
| <tr class="separator:a666be9ce0980aeda2921c2229c003db8"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a46e87bd20edc2a00c492e2be2c43a644" id="r_a46e87bd20edc2a00c492e2be2c43a644"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a46e87bd20edc2a00c492e2be2c43a644">createProducerAsync</a> (const std::string &topic, <a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a> conf, CreateProducerCallback callback)</td></tr> |
| <tr class="separator:a46e87bd20edc2a00c492e2be2c43a644"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9f32b4d1101f8f2fb5029013c87779ab" id="r_a9f32b4d1101f8f2fb5029013c87779ab"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a9f32b4d1101f8f2fb5029013c87779ab">subscribe</a> (const std::string &topic, const std::string &subscriptionName, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> &consumer)</td></tr> |
| <tr class="separator:a9f32b4d1101f8f2fb5029013c87779ab"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a11b3ca7d9174a0912bf51b742f7f825a" id="r_a11b3ca7d9174a0912bf51b742f7f825a"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a11b3ca7d9174a0912bf51b742f7f825a">subscribe</a> (const std::string &topic, const std::string &subscriptionName, const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> &conf, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> &consumer)</td></tr> |
| <tr class="separator:a11b3ca7d9174a0912bf51b742f7f825a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a534d1cc013112c4e9eeee037b42b4815" id="r_a534d1cc013112c4e9eeee037b42b4815"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a534d1cc013112c4e9eeee037b42b4815">subscribeAsync</a> (const std::string &topic, const std::string &subscriptionName, SubscribeCallback callback)</td></tr> |
| <tr class="separator:a534d1cc013112c4e9eeee037b42b4815"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a85d82595856f515b22acb623e84daa4b" id="r_a85d82595856f515b22acb623e84daa4b"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a85d82595856f515b22acb623e84daa4b">subscribeAsync</a> (const std::string &topic, const std::string &subscriptionName, const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> &conf, SubscribeCallback callback)</td></tr> |
| <tr class="separator:a85d82595856f515b22acb623e84daa4b"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aea2d7918286ecd127751d06e191a5471" id="r_aea2d7918286ecd127751d06e191a5471"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#aea2d7918286ecd127751d06e191a5471">subscribe</a> (const std::vector< std::string > &topics, const std::string &subscriptionName, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> &consumer)</td></tr> |
| <tr class="separator:aea2d7918286ecd127751d06e191a5471"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9188d5fafbb23da16f859592316947e4" id="r_a9188d5fafbb23da16f859592316947e4"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a9188d5fafbb23da16f859592316947e4">subscribe</a> (const std::vector< std::string > &topics, const std::string &subscriptionName, const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> &conf, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> &consumer)</td></tr> |
| <tr class="separator:a9188d5fafbb23da16f859592316947e4"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a33f76797dfbd57daf4c72f96c659fe77" id="r_a33f76797dfbd57daf4c72f96c659fe77"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a33f76797dfbd57daf4c72f96c659fe77">subscribeAsync</a> (const std::vector< std::string > &topics, const std::string &subscriptionName, SubscribeCallback callback)</td></tr> |
| <tr class="separator:a33f76797dfbd57daf4c72f96c659fe77"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:afcfcc1f9bcc63527063ae1b60a41ba8e" id="r_afcfcc1f9bcc63527063ae1b60a41ba8e"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#afcfcc1f9bcc63527063ae1b60a41ba8e">subscribeAsync</a> (const std::vector< std::string > &topics, const std::string &subscriptionName, const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> &conf, SubscribeCallback callback)</td></tr> |
| <tr class="separator:afcfcc1f9bcc63527063ae1b60a41ba8e"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a086549ca0d057be1e9d00ca483995621" id="r_a086549ca0d057be1e9d00ca483995621"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a086549ca0d057be1e9d00ca483995621">subscribeWithRegex</a> (const std::string &regexPattern, const std::string &subscriptionName, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> &consumer)</td></tr> |
| <tr class="separator:a086549ca0d057be1e9d00ca483995621"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a11016481c032f7d07e3ab5be341c9344" id="r_a11016481c032f7d07e3ab5be341c9344"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a11016481c032f7d07e3ab5be341c9344">subscribeWithRegex</a> (const std::string &regexPattern, const std::string &subscriptionName, const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> &conf, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> &consumer)</td></tr> |
| <tr class="separator:a11016481c032f7d07e3ab5be341c9344"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a49a6024ae4ff44e1e02a59bc08d28c7a" id="r_a49a6024ae4ff44e1e02a59bc08d28c7a"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a49a6024ae4ff44e1e02a59bc08d28c7a">subscribeWithRegexAsync</a> (const std::string &regexPattern, const std::string &subscriptionName, SubscribeCallback callback)</td></tr> |
| <tr class="separator:a49a6024ae4ff44e1e02a59bc08d28c7a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:abef60cadedd17903a245dbaa8368381a" id="r_abef60cadedd17903a245dbaa8368381a"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#abef60cadedd17903a245dbaa8368381a">subscribeWithRegexAsync</a> (const std::string &regexPattern, const std::string &subscriptionName, const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> &conf, SubscribeCallback callback)</td></tr> |
| <tr class="separator:abef60cadedd17903a245dbaa8368381a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad2f6404e06200714e1fe82419b7c963a" id="r_ad2f6404e06200714e1fe82419b7c963a"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#ad2f6404e06200714e1fe82419b7c963a">createReader</a> (const std::string &topic, const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &startMessageId, const <a class="el" href="classpulsar_1_1_reader_configuration.html">ReaderConfiguration</a> &conf, <a class="el" href="classpulsar_1_1_reader.html">Reader</a> &reader)</td></tr> |
| <tr class="separator:ad2f6404e06200714e1fe82419b7c963a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ab837056e2ea59c8c55d83d6451ee7b08" id="r_ab837056e2ea59c8c55d83d6451ee7b08"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#ab837056e2ea59c8c55d83d6451ee7b08">createReaderAsync</a> (const std::string &topic, const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &startMessageId, const <a class="el" href="classpulsar_1_1_reader_configuration.html">ReaderConfiguration</a> &conf, ReaderCallback callback)</td></tr> |
| <tr class="separator:ab837056e2ea59c8c55d83d6451ee7b08"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aafa5591b8fc3241e50c2b1f2e3bafe24" id="r_aafa5591b8fc3241e50c2b1f2e3bafe24"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#aafa5591b8fc3241e50c2b1f2e3bafe24">createTableView</a> (const std::string &topic, const <a class="el" href="structpulsar_1_1_table_view_configuration.html">TableViewConfiguration</a> &conf, <a class="el" href="classpulsar_1_1_table_view.html">TableView</a> &tableView)</td></tr> |
| <tr class="separator:aafa5591b8fc3241e50c2b1f2e3bafe24"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:addf53e700657aeaf0bcaa8c5ddd89e84" id="r_addf53e700657aeaf0bcaa8c5ddd89e84"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#addf53e700657aeaf0bcaa8c5ddd89e84">createTableViewAsync</a> (const std::string &topic, const <a class="el" href="structpulsar_1_1_table_view_configuration.html">TableViewConfiguration</a> &conf, TableViewCallback callBack)</td></tr> |
| <tr class="separator:addf53e700657aeaf0bcaa8c5ddd89e84"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a208629aff52395ad0072622ae82f5657" id="r_a208629aff52395ad0072622ae82f5657"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a208629aff52395ad0072622ae82f5657">getPartitionsForTopic</a> (const std::string &topic, std::vector< std::string > &partitions)</td></tr> |
| <tr class="separator:a208629aff52395ad0072622ae82f5657"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a2c3746c12dd5a531efcf2e8af96a3337" id="r_a2c3746c12dd5a531efcf2e8af96a3337"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a2c3746c12dd5a531efcf2e8af96a3337">getPartitionsForTopicAsync</a> (const std::string &topic, GetPartitionsCallback callback)</td></tr> |
| <tr class="separator:a2c3746c12dd5a531efcf2e8af96a3337"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac3f0a65b099f88781548d4fad41685ac" id="r_ac3f0a65b099f88781548d4fad41685ac"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#ac3f0a65b099f88781548d4fad41685ac">close</a> ()</td></tr> |
| <tr class="separator:ac3f0a65b099f88781548d4fad41685ac"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad2701d78fca53d5261616ca53381241d" id="r_ad2701d78fca53d5261616ca53381241d"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#ad2701d78fca53d5261616ca53381241d">closeAsync</a> (CloseCallback callback)</td></tr> |
| <tr class="separator:ad2701d78fca53d5261616ca53381241d"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aecac8bf91b474339455fe0519f6ba71e" id="r_aecac8bf91b474339455fe0519f6ba71e"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#aecac8bf91b474339455fe0519f6ba71e">shutdown</a> ()</td></tr> |
| <tr class="separator:aecac8bf91b474339455fe0519f6ba71e"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a5225a8d2b121cce6e205ef6e2471cdbc" id="r_a5225a8d2b121cce6e205ef6e2471cdbc"><td class="memItemLeft" align="right" valign="top">uint64_t </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a5225a8d2b121cce6e205ef6e2471cdbc">getNumberOfProducers</a> ()</td></tr> |
| <tr class="memdesc:a5225a8d2b121cce6e205ef6e2471cdbc"><td class="mdescLeft"> </td><td class="mdescRight">Get the number of alive producers on the current client. <br /></td></tr> |
| <tr class="separator:a5225a8d2b121cce6e205ef6e2471cdbc"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a1134874e191f8bf395c020f1ed3b2423" id="r_a1134874e191f8bf395c020f1ed3b2423"><td class="memItemLeft" align="right" valign="top">uint64_t </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#a1134874e191f8bf395c020f1ed3b2423">getNumberOfConsumers</a> ()</td></tr> |
| <tr class="memdesc:a1134874e191f8bf395c020f1ed3b2423"><td class="mdescLeft"> </td><td class="mdescRight">Get the number of alive consumers on the current client. <br /></td></tr> |
| <tr class="separator:a1134874e191f8bf395c020f1ed3b2423"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa24ed12d3228c31c923e33fee1eb6f55" id="r_aa24ed12d3228c31c923e33fee1eb6f55"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html#aa24ed12d3228c31c923e33fee1eb6f55">getSchemaInfoAsync</a> (const std::string &topic, int64_t version, std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, const <a class="el" href="classpulsar_1_1_schema_info.html">SchemaInfo</a> &)> callback)</td></tr> |
| <tr class="separator:aa24ed12d3228c31c923e33fee1eb6f55"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 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="separator:ac1899b25eaceed54fad39b7b44d8a00f"><td class="memSeparator" colspan="2"> </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="separator:aec24ec969dcf4df0185304ccbf6d653c"><td class="memSeparator" colspan="2"> </td></tr> |
| </table> |
| <h2 class="groupheader">Constructor & Destructor Documentation</h2> |
| <a id="acab90af5d0542803bc1d10e68d27414f" name="acab90af5d0542803bc1d10e68d27414f"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#acab90af5d0542803bc1d10e68d27414f">◆ </a></span>Client() <span class="overload">[1/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">pulsar::Client::Client </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>serviceUrl</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Create a Pulsar client object connecting to the specified cluster address and using the default configuration.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">serviceUrl</td><td>the Pulsar endpoint to use (eg: pulsar://localhost:6650) </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="exception"><dt>Exceptions</dt><dd> |
| <table class="exception"> |
| <tr><td class="paramname">std::invalid_argument</td><td>if <code>serviceUrl</code> is invalid </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a148122b14f22844d359c35c084907962" name="a148122b14f22844d359c35c084907962"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a148122b14f22844d359c35c084907962">◆ </a></span>Client() <span class="overload">[2/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">pulsar::Client::Client </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>serviceUrl</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_client_configuration.html">ClientConfiguration</a> & </td> |
| <td class="paramname"><em>clientConfiguration</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Create a Pulsar client object connecting to the specified cluster address and using the specified configuration.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">serviceUrl</td><td>the Pulsar endpoint to use (eg: <a href="http://brokerv2-pdev.messaging.corp.gq1.yahoo.com:4080">http://brokerv2-pdev.messaging.corp.gq1.yahoo.com:4080</a> for Sandbox access) </td></tr> |
| <tr><td class="paramname">clientConfiguration</td><td>the client configuration to use </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="exception"><dt>Exceptions</dt><dd> |
| <table class="exception"> |
| <tr><td class="paramname">std::invalid_argument</td><td>if <code>serviceUrl</code> is invalid </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <h2 class="groupheader">Member Function Documentation</h2> |
| <a id="ac3f0a65b099f88781548d4fad41685ac" name="ac3f0a65b099f88781548d4fad41685ac"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ac3f0a65b099f88781548d4fad41685ac">◆ </a></span>close()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::close </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <dl class="section return"><dt>Returns</dt><dd></dd></dl> |
| |
| </div> |
| </div> |
| <a id="ad2701d78fca53d5261616ca53381241d" name="ad2701d78fca53d5261616ca53381241d"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ad2701d78fca53d5261616ca53381241d">◆ </a></span>closeAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::closeAsync </td> |
| <td>(</td> |
| <td class="paramtype">CloseCallback </td> |
| <td class="paramname"><em>callback</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously close the Pulsar client and release all resources.</p> |
| <p>All producers, consumers, and readers are orderly closed. The client waits until all pending write requests are persisted.</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 Pulsar client is asynchronously closed successfully or not </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="aae7658dee80ad23b418cfb7e12f5df05" name="aae7658dee80ad23b418cfb7e12f5df05"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#aae7658dee80ad23b418cfb7e12f5df05">◆ </a></span>createProducer() <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#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::createProducer </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_producer.html">Producer</a> & </td> |
| <td class="paramname"><em>producer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Create a producer with specified configuration</p> |
| <dl class="section see"><dt>See also</dt><dd><a class="el" href="classpulsar_1_1_client.html#aae7658dee80ad23b418cfb7e12f5df05">createProducer(const std::string&, const ProducerConfiguration&, Producer&)</a></dd></dl> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the topic where the new producer will publish </td></tr> |
| <tr><td class="paramname">conf</td><td>the producer config to use </td></tr> |
| <tr><td class="paramname">producer</td><td>a non-const reference where the new producer will be copied </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>ResultOk if the producer has been successfully created </dd> |
| <dd> |
| ResultError if there was an error </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a96f49cc0ce27bfe68d75224991f0ba52" name="a96f49cc0ce27bfe68d75224991f0ba52"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a96f49cc0ce27bfe68d75224991f0ba52">◆ </a></span>createProducer() <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#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::createProducer </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_producer.html">Producer</a> & </td> |
| <td class="paramname"><em>producer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Create a producer with default configuration</p> |
| <dl class="section see"><dt>See also</dt><dd><a class="el" href="classpulsar_1_1_client.html#aae7658dee80ad23b418cfb7e12f5df05">createProducer(const std::string&, const ProducerConfiguration&, Producer&)</a></dd></dl> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the topic where the new producer will publish </td></tr> |
| <tr><td class="paramname">producer</td><td>a non-const reference where the new producer will be copied </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>ResultOk if the producer has been successfully created </dd> |
| <dd> |
| ResultError if there was an error </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a666be9ce0980aeda2921c2229c003db8" name="a666be9ce0980aeda2921c2229c003db8"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a666be9ce0980aeda2921c2229c003db8">◆ </a></span>createProducerAsync() <span class="overload">[1/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::createProducerAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">CreateProducerCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously create a producer with the default <a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a> for publishing on a specific topic</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the name of the topic where to produce </td></tr> |
| <tr><td class="paramname">callback</td><td>the callback that is triggered when the producer is created successfully or not </td></tr> |
| <tr><td class="paramname">callback</td><td>Callback function that is invoked when the operation is completed </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a46e87bd20edc2a00c492e2be2c43a644" name="a46e87bd20edc2a00c492e2be2c43a644"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a46e87bd20edc2a00c492e2be2c43a644">◆ </a></span>createProducerAsync() <span class="overload">[2/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::createProducerAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a> </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">CreateProducerCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously create a producer with the customized <a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a> for publishing on a specific topic</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the name of the topic where to produce </td></tr> |
| <tr><td class="paramname">conf</td><td>the customized <a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a> </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="ad2f6404e06200714e1fe82419b7c963a" name="ad2f6404e06200714e1fe82419b7c963a"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ad2f6404e06200714e1fe82419b7c963a">◆ </a></span>createReader()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::createReader </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> & </td> |
| <td class="paramname"><em>startMessageId</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_reader_configuration.html">ReaderConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_reader.html">Reader</a> & </td> |
| <td class="paramname"><em>reader</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Create a topic reader with given <code class="JavaDocCode">ReaderConfiguration</code> for reading messages from the specified topic. </p> |
| <p>The <a class="el" href="classpulsar_1_1_reader.html">Reader</a> provides a low-level abstraction that allows for manual positioning in the topic, without using a subscription. <a class="el" href="classpulsar_1_1_reader.html">Reader</a> can only work on non-partitioned topics. </p> |
| <p>The initial reader positioning is done by specifying a message id. The options are: </p><ul> |
| <li> |
| <code><a class="el" href="classpulsar_1_1_message_id.html#a3b0079713b68d0a9d03c269dc2ba2fff">MessageId.earliest</a></code> : Start reading from the earliest message available in the topic </li> |
| <li> |
| <code><a class="el" href="classpulsar_1_1_message_id.html#af9c67f2e12e102b07c609a8da5740976">MessageId.latest</a></code> : Start reading from the end topic, only getting messages published after the reader was created </li> |
| <li> |
| <code><a class="el" href="classpulsar_1_1_message_id.html">MessageId</a></code> : When passing a particular message id, the reader will position itself on that specific position. The first message to be read will be the message next to the specified messageId. </li> |
| </ul> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>The name of the topic where to read </td></tr> |
| <tr><td class="paramname">startMessageId</td><td>The message id where the reader will position itself. The first message returned will be the one after the specified startMessageId </td></tr> |
| <tr><td class="paramname">conf</td><td>The <code class="JavaDocCode">ReaderConfiguration</code> object </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>The <code class="JavaDocCode">Reader</code> object </dd></dl> |
| |
| </div> |
| </div> |
| <a id="ab837056e2ea59c8c55d83d6451ee7b08" name="ab837056e2ea59c8c55d83d6451ee7b08"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ab837056e2ea59c8c55d83d6451ee7b08">◆ </a></span>createReaderAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::createReaderAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> & </td> |
| <td class="paramname"><em>startMessageId</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_reader_configuration.html">ReaderConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">ReaderCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously create a topic reader with the customized <a class="el" href="classpulsar_1_1_reader_configuration.html">ReaderConfiguration</a> for reading messages from the specified topic.</p> |
| <p>The <a class="el" href="classpulsar_1_1_reader.html">Reader</a> provides a low-level abstraction that allows for manual positioning in the topic, without using a subscription. The reader can only work on non-partitioned topics.</p> |
| <p>The initial reader positioning is done by specifying a message ID. The options are as below: </p><ul> |
| <li> |
| <code><a class="el" href="classpulsar_1_1_message_id.html#a3b0079713b68d0a9d03c269dc2ba2fff">MessageId.earliest</a></code> : start reading from the earliest message available in the topic </li> |
| <li> |
| <code><a class="el" href="classpulsar_1_1_message_id.html#af9c67f2e12e102b07c609a8da5740976">MessageId.latest</a></code> : start reading from the latest topic, only getting messages published after the reader was created </li> |
| <li> |
| <code><a class="el" href="classpulsar_1_1_message_id.html">MessageId</a></code> : when passing a particular message ID, the reader positions itself on that is the message next to the specified messageId. </li> |
| </ul> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the name of the topic where to read </td></tr> |
| <tr><td class="paramname">startMessageId</td><td>the message ID where the reader positions itself. The first message returned is the one after the specified startMessageId </td></tr> |
| <tr><td class="paramname">conf</td><td>the <a class="el" href="classpulsar_1_1_reader_configuration.html">ReaderConfiguration</a> object </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>the <a class="el" href="classpulsar_1_1_reader.html">Reader</a> object </dd></dl> |
| |
| </div> |
| </div> |
| <a id="aafa5591b8fc3241e50c2b1f2e3bafe24" name="aafa5591b8fc3241e50c2b1f2e3bafe24"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#aafa5591b8fc3241e50c2b1f2e3bafe24">◆ </a></span>createTableView()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::createTableView </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="structpulsar_1_1_table_view_configuration.html">TableViewConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_table_view.html">TableView</a> & </td> |
| <td class="paramname"><em>tableView</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Create a table view with given <code class="JavaDocCode">TableViewConfiguration</code> for specified topic.</p> |
| <p>The <a class="el" href="classpulsar_1_1_table_view.html">TableView</a> provides a key-value map view of a compacted topic. Messages without keys will be ignored.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>The name of the topic. </td></tr> |
| <tr><td class="paramname">conf</td><td>The <code class="JavaDocCode">TableViewConfiguration</code> object </td></tr> |
| <tr><td class="paramname">tableView</td><td>The <code class="JavaDocCode">TableView</code> object </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>Returned when the <a class="el" href="classpulsar_1_1_table_view.html">TableView</a> is successfully linked to the topic and the map is built from a message that already exists </dd></dl> |
| |
| </div> |
| </div> |
| <a id="addf53e700657aeaf0bcaa8c5ddd89e84" name="addf53e700657aeaf0bcaa8c5ddd89e84"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#addf53e700657aeaf0bcaa8c5ddd89e84">◆ </a></span>createTableViewAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::createTableViewAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="structpulsar_1_1_table_view_configuration.html">TableViewConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">TableViewCallback </td> |
| <td class="paramname"><em>callBack</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Async create a table view with given <code class="JavaDocCode">TableViewConfiguration</code> for specified topic.</p> |
| <p>The <a class="el" href="classpulsar_1_1_table_view.html">TableView</a> provides a key-value map view of a compacted topic. Messages without keys will be ignored.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>The name of the topic. </td></tr> |
| <tr><td class="paramname">conf</td><td>The <code class="JavaDocCode">TableViewConfiguration</code> object </td></tr> |
| <tr><td class="paramname">callBack</td><td>The callback that is triggered when the <a class="el" href="classpulsar_1_1_table_view.html">TableView</a> is successfully linked to the topic and the map is built from a message that already exists </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a1134874e191f8bf395c020f1ed3b2423" name="a1134874e191f8bf395c020f1ed3b2423"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a1134874e191f8bf395c020f1ed3b2423">◆ </a></span>getNumberOfConsumers()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">uint64_t pulsar::Client::getNumberOfConsumers </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Get the number of alive consumers on the current client. </p> |
| <dl class="section return"><dt>Returns</dt><dd>The number of alive consumers on the current client. </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a5225a8d2b121cce6e205ef6e2471cdbc" name="a5225a8d2b121cce6e205ef6e2471cdbc"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a5225a8d2b121cce6e205ef6e2471cdbc">◆ </a></span>getNumberOfProducers()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">uint64_t pulsar::Client::getNumberOfProducers </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Get the number of alive producers on the current client. </p> |
| <dl class="section return"><dt>Returns</dt><dd>The number of alive producers on the current client. </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a208629aff52395ad0072622ae82f5657" name="a208629aff52395ad0072622ae82f5657"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a208629aff52395ad0072622ae82f5657">◆ </a></span>getPartitionsForTopic()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::getPartitionsForTopic </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">std::vector< std::string > & </td> |
| <td class="paramname"><em>partitions</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Get the list of partitions for a given topic.</p> |
| <p>If the topic is partitioned, this will return a list of partition names. If the topic is not partitioned, the returned list will contain the topic name itself.</p> |
| <p>This can be used to discover the partitions and create <a class="el" href="classpulsar_1_1_reader.html">Reader</a>, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> or <a class="el" href="classpulsar_1_1_producer.html">Producer</a> instances directly on a particular partition.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the topic name </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section since"><dt>Since</dt><dd>2.3.0 </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a2c3746c12dd5a531efcf2e8af96a3337" name="a2c3746c12dd5a531efcf2e8af96a3337"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a2c3746c12dd5a531efcf2e8af96a3337">◆ </a></span>getPartitionsForTopicAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::getPartitionsForTopicAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">GetPartitionsCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Get the list of partitions for a given topic in asynchronous mode.</p> |
| <p>If the topic is partitioned, this will return a list of partition names. If the topic is not partitioned, the returned list will contain the topic name itself.</p> |
| <p>This can be used to discover the partitions and create <a class="el" href="classpulsar_1_1_reader.html">Reader</a>, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> or <a class="el" href="classpulsar_1_1_producer.html">Producer</a> instances directly on a particular partition.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the topic name </td></tr> |
| <tr><td class="paramname">callback</td><td>the callback that will be invoked when the list of partitions is available </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section since"><dt>Since</dt><dd>2.3.0 </dd></dl> |
| |
| </div> |
| </div> |
| <a id="aa24ed12d3228c31c923e33fee1eb6f55" name="aa24ed12d3228c31c923e33fee1eb6f55"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#aa24ed12d3228c31c923e33fee1eb6f55">◆ </a></span>getSchemaInfoAsync()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::getSchemaInfoAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">int64_t </td> |
| <td class="paramname"><em>version</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, const <a class="el" href="classpulsar_1_1_schema_info.html">SchemaInfo</a> &)> </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously get the <a class="el" href="classpulsar_1_1_schema_info.html">SchemaInfo</a> of a topic and a specific version.</p> |
| <p>@topic the topic name </p><dl class="section version"><dt>Version</dt><dd>the schema version, see <a class="el" href="classpulsar_1_1_message.html#a4a4d35b3098d18b04f998764d3c2ce76">Message::getLongSchemaVersion</a> @callback the callback that is triggered when the <a class="el" href="classpulsar_1_1_schema_info.html">SchemaInfo</a> is retrieved successfully or not </dd></dl> |
| |
| </div> |
| </div> |
| <a id="aecac8bf91b474339455fe0519f6ba71e" name="aecac8bf91b474339455fe0519f6ba71e"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#aecac8bf91b474339455fe0519f6ba71e">◆ </a></span>shutdown()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::shutdown </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Perform immediate shutdown of Pulsar client.</p> |
| <p>Release all resources and close all producer, consumer, and readers without waiting for ongoing operations to complete. </p> |
| |
| </div> |
| </div> |
| <a id="a11b3ca7d9174a0912bf51b742f7f825a" name="a11b3ca7d9174a0912bf51b742f7f825a"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a11b3ca7d9174a0912bf51b742f7f825a">◆ </a></span>subscribe() <span class="overload">[1/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::subscribe </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> & </td> |
| <td class="paramname"><em>consumer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Subscribe to a given topic and subscription combination with the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a></p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramdir"></td><td class="paramname">topic</td><td>the topic name </td></tr> |
| <tr><td class="paramdir"></td><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramdir">[out]</td><td class="paramname">consumer</td><td>the consumer instance to be returned </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>ResultOk if it subscribes to the topic successfully </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a9f32b4d1101f8f2fb5029013c87779ab" name="a9f32b4d1101f8f2fb5029013c87779ab"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a9f32b4d1101f8f2fb5029013c87779ab">◆ </a></span>subscribe() <span class="overload">[2/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::subscribe </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> & </td> |
| <td class="paramname"><em>consumer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Subscribe to a given topic and subscription combination with the default <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a></p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramdir"></td><td class="paramname">topic</td><td>the topic name </td></tr> |
| <tr><td class="paramdir"></td><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramdir">[out]</td><td class="paramname">consumer</td><td>the consumer instance to be returned </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>ResultOk if it subscribes to the topic successfully </dd></dl> |
| |
| </div> |
| </div> |
| <a id="a9188d5fafbb23da16f859592316947e4" name="a9188d5fafbb23da16f859592316947e4"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a9188d5fafbb23da16f859592316947e4">◆ </a></span>subscribe() <span class="overload">[3/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::subscribe </td> |
| <td>(</td> |
| <td class="paramtype">const std::vector< std::string > & </td> |
| <td class="paramname"><em>topics</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> & </td> |
| <td class="paramname"><em>consumer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Subscribe to multiple topics with the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> under the same namespace</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramdir"></td><td class="paramname">topics</td><td>a list of topic names to subscribe to </td></tr> |
| <tr><td class="paramdir"></td><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramdir"></td><td class="paramname">conf</td><td>the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> </td></tr> |
| <tr><td class="paramdir">[out]</td><td class="paramname">consumer</td><td>the consumer instance to be returned </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="aea2d7918286ecd127751d06e191a5471" name="aea2d7918286ecd127751d06e191a5471"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#aea2d7918286ecd127751d06e191a5471">◆ </a></span>subscribe() <span class="overload">[4/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::subscribe </td> |
| <td>(</td> |
| <td class="paramtype">const std::vector< std::string > & </td> |
| <td class="paramname"><em>topics</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> & </td> |
| <td class="paramname"><em>consumer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Subscribe to multiple topics under the same namespace.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramdir"></td><td class="paramname">topics</td><td>a list of topic names to subscribe to </td></tr> |
| <tr><td class="paramdir"></td><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramdir">[out]</td><td class="paramname">consumer</td><td>the consumer instance to be returned </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a85d82595856f515b22acb623e84daa4b" name="a85d82595856f515b22acb623e84daa4b"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a85d82595856f515b22acb623e84daa4b">◆ </a></span>subscribeAsync() <span class="overload">[1/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::subscribeAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">SubscribeCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously subscribe to a given topic and subscription combination with the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a></p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the topic name </td></tr> |
| <tr><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramname">conf</td><td>the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> </td></tr> |
| <tr><td class="paramname">callback</td><td>the callback that is triggered when a given topic and subscription combination with the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> are asynchronously subscribed successfully or not </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a534d1cc013112c4e9eeee037b42b4815" name="a534d1cc013112c4e9eeee037b42b4815"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a534d1cc013112c4e9eeee037b42b4815">◆ </a></span>subscribeAsync() <span class="overload">[2/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::subscribeAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>topic</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">SubscribeCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously subscribe to a given topic and subscription combination with the default <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a></p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topic</td><td>the topic name </td></tr> |
| <tr><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramname">callback</td><td>the callback that is triggered when a given topic and subscription combination with the default <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> are asynchronously subscribed successfully or not </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="afcfcc1f9bcc63527063ae1b60a41ba8e" name="afcfcc1f9bcc63527063ae1b60a41ba8e"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#afcfcc1f9bcc63527063ae1b60a41ba8e">◆ </a></span>subscribeAsync() <span class="overload">[3/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::subscribeAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::vector< std::string > & </td> |
| <td class="paramname"><em>topics</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">SubscribeCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously subscribe to a list of topics and subscription combination using the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a></p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topics</td><td>the topic list </td></tr> |
| <tr><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramname">conf</td><td>the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> </td></tr> |
| <tr><td class="paramname">callback</td><td>the callback that is triggered when a list of topics and subscription combination using the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> are asynchronously subscribed successfully or not </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a33f76797dfbd57daf4c72f96c659fe77" name="a33f76797dfbd57daf4c72f96c659fe77"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a33f76797dfbd57daf4c72f96c659fe77">◆ </a></span>subscribeAsync() <span class="overload">[4/4]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::subscribeAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::vector< std::string > & </td> |
| <td class="paramname"><em>topics</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">SubscribeCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously subscribe to a list of topics and subscription combination using the default <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a></p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">topics</td><td>the topic list </td></tr> |
| <tr><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramname">callback</td><td>the callback that is triggered when a list of topics and subscription combination using the default <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> are asynchronously subscribed successfully or not </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a11016481c032f7d07e3ab5be341c9344" name="a11016481c032f7d07e3ab5be341c9344"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a11016481c032f7d07e3ab5be341c9344">◆ </a></span>subscribeWithRegex() <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#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::subscribeWithRegex </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>regexPattern</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> & </td> |
| <td class="paramname"><em>consumer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Subscribe to multiple topics (which match given regexPatterns) with the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> under the same namespace </p> |
| |
| </div> |
| </div> |
| <a id="a086549ca0d057be1e9d00ca483995621" name="a086549ca0d057be1e9d00ca483995621"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a086549ca0d057be1e9d00ca483995621">◆ </a></span>subscribeWithRegex() <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#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> pulsar::Client::subscribeWithRegex </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>regexPattern</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> & </td> |
| <td class="paramname"><em>consumer</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Subscribe to multiple topics, which match given regexPattern, under the same namespace. </p> |
| |
| </div> |
| </div> |
| <a id="abef60cadedd17903a245dbaa8368381a" name="abef60cadedd17903a245dbaa8368381a"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#abef60cadedd17903a245dbaa8368381a">◆ </a></span>subscribeWithRegexAsync() <span class="overload">[1/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::subscribeWithRegexAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>regexPattern</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> & </td> |
| <td class="paramname"><em>conf</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">SubscribeCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously subscribe to multiple topics (which match given regexPatterns) with the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> under the same namespace</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">regexPattern</td><td>the regular expression for topics pattern </td></tr> |
| <tr><td class="paramname">subscriptionName</td><td>the subscription name </td></tr> |
| <tr><td class="paramname">conf</td><td>the <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> </td></tr> |
| <tr><td class="paramname">callback</td><td>the callback that is triggered when multiple topics with the customized <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> under the same namespace are asynchronously subscribed successfully or not </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| <a id="a49a6024ae4ff44e1e02a59bc08d28c7a" name="a49a6024ae4ff44e1e02a59bc08d28c7a"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a49a6024ae4ff44e1e02a59bc08d28c7a">◆ </a></span>subscribeWithRegexAsync() <span class="overload">[2/2]</span></h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void pulsar::Client::subscribeWithRegexAsync </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>regexPattern</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>subscriptionName</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">SubscribeCallback </td> |
| <td class="paramname"><em>callback</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Asynchronously subscribe to multiple topics (which match given regexPatterns) with the default <a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a> under the same namespace</p> |
| <dl class="section see"><dt>See also</dt><dd><a class="el" href="classpulsar_1_1_client.html#abef60cadedd17903a245dbaa8368381a">subscribeWithRegexAsync(const std::string&, const std::string&, const ConsumerConfiguration&, |
| SubscribeCallback)</a> </dd></dl> |
| |
| </div> |
| </div> |
| <hr/>The documentation for this class was generated from the following file:<ul> |
| <li>include/pulsar/<a class="el" href="_client_8h_source.html">Client.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.9.8 |
| </small></address> |
| </body> |
| </html> |
