|
class | ClientImpl |
|
class | PulsarWrapper |
|
◆ getAuth()
- Returns
- the authentication data
◆ getConcurrentLookupRequest()
int pulsar::ClientConfiguration::getConcurrentLookupRequest |
( |
| ) |
const |
- Returns
- Get configured total allowed concurrent lookup-request.
◆ getIOThreads()
int pulsar::ClientConfiguration::getIOThreads |
( |
| ) |
const |
- Returns
- the number of IO threads to use
◆ getLogConfFilePath()
const std::string& pulsar::ClientConfiguration::getLogConfFilePath |
( |
| ) |
const |
Get the path of log configuration file (log4cpp)
◆ getMessageListenerThreads()
int pulsar::ClientConfiguration::getMessageListenerThreads |
( |
| ) |
const |
- Returns
- the number of IO threads to use
◆ getOperationTimeoutSeconds()
int pulsar::ClientConfiguration::getOperationTimeoutSeconds |
( |
| ) |
const |
- Returns
- the client operations timeout in seconds
◆ setAuth()
ClientConfiguration& pulsar::ClientConfiguration::setAuth |
( |
const AuthenticationPtr & |
authentication | ) |
|
Set the authentication method to be used with the broker
- Parameters
-
authentication | the authentication data to use |
◆ setConcurrentLookupRequest()
ClientConfiguration& pulsar::ClientConfiguration::setConcurrentLookupRequest |
( |
int |
concurrentLookupRequest | ) |
|
Number of concurrent lookup-requests allowed on each broker-connection to prevent overload on broker. (default: 5000) It should be configured with higher value only in case of it requires to produce/subscribe on thousands of topic using created PulsarClient
- Parameters
-
◆ setIOThreads()
Set the number of IO threads to be used by the Pulsar client. Default is 1 thread.
- Parameters
-
◆ setLogConfFilePath()
ClientConfiguration& pulsar::ClientConfiguration::setLogConfFilePath |
( |
const std::string & |
logConfFilePath | ) |
|
Initialize the log configuration
- Parameters
-
logConfFilePath | path of the configuration file |
◆ setMessageListenerThreads()
Set the number of threads to be used by the Pulsar client when delivering messages through message listener. Default is 1 thread per Pulsar client.
If using more than 1 thread, messages for distinct MessageListener will be delivered in different threads, however a single MessageListener will always be assigned to the same thread.
- Parameters
-
◆ setOperationTimeoutSeconds()
Set timeout on client operations (subscribe, create producer, close, unsubscribe) Default is 30 seconds.
- Parameters
-
timeout | the timeout after which the operation will be considered as failed |
The documentation for this class was generated from the following file: