pulsar-client-cpp
|
Classes | |
class | Authentication |
class | AuthenticationDataProvider |
class | AuthFactory |
class | BatchMessageId |
class | BrokerConsumerStats |
class | Client |
class | ClientConfiguration |
class | Consumer |
class | ConsumerConfiguration |
class | Message |
class | MessageBuilder |
class | MessageId |
class | MessageRoutingPolicy |
class | Producer |
class | ProducerConfiguration |
Typedefs | |
typedef boost::shared_ptr< AuthenticationDataProvider > | AuthenticationDataPtr |
typedef boost::shared_ptr< Authentication > | AuthenticationPtr |
typedef std::map< std::string, std::string > | ParamMap |
typedef boost::function< void(Result result, BrokerConsumerStats brokerConsumerStats)> | BrokerConsumerStatsCallback |
typedef boost::function< void(Result, Producer)> | CreateProducerCallback |
typedef boost::function< void(Result, Consumer)> | SubscribeCallback |
typedef boost::function< void(Result)> | CloseCallback |
typedef boost::function< void(Result result)> | ResultCallback |
Callback definition for non-data operation. | |
typedef boost::function< void(Consumer consumer, const Message &msg)> | MessageListener |
Callback definition for MessageListener. | |
typedef boost::shared_ptr< MessageRoutingPolicy > | MessageRoutingPolicyPtr |
typedef boost::function< void(Result, const Message &msg)> | SendCallback |
Functions | |
const char * | strResult (Result result) |
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
enum pulsar::ConsumerType |
enum pulsar::Result |
Collection of return codes
Enumerator | |
---|---|
ResultUnknownError | Operation successful. |
ResultInvalidConfiguration | Unknown error happened on broker. |
ResultTimeout | Invalid configuration. |
ResultLookupError | Operation timed out. |
ResultConnectError | Broker lookup failed. |
ResultReadError | Failed to connect to broker. |
ResultAuthenticationError | Failed to read from socket. |
ResultAuthorizationError | Authentication failed on broker. |
ResultErrorGettingAuthenticationData | Client is not authorized to create producer/consumer. |
ResultBrokerMetadataError | Client cannot find authorization data. |
ResultBrokerPersistenceError | Broker failed in updating metadata. |
ResultChecksumError | Broker failed to persist entry. |
ResultConsumerBusy | Corrupt message checksum failure. |
ResultNotConnected | Exclusive consumer is already connected. |
ResultAlreadyClosed | Producer/Consumer is not currently connected to broker. |
ResultInvalidMessage | Producer/Consumer is already closed and not accepting any operation. |
ResultConsumerNotInitialized | Error in publishing an already used message. |
ResultProducerNotInitialized | Consumer is not initialized. |
ResultTooManyLookupRequestException | Producer is not initialized. |
ResultInvalidTopicName | Too Many concurrent LookupRequest. |
ResultInvalidUrl | Invalid topic name. |
ResultServiceUnitNotReady | Client Initialized with Invalid Broker Url (VIP Url passed to Client Constructor) |
ResultOperationNotSupported | Service Unit unloaded between client did lookup and producer/consumer got created. |
ResultProducerBlockedQuotaExceededException | Producer is blocked. |
ResultProducerQueueIsFull | Producer is getting exception. |
ResultMessageTooBig | Producer queue is full. |
ResultTopicNotFound | Trying to send a messages exceeding the max size. |
ResultSubscriptionNotFound | Topic not found. |
ResultConsumerNotFound | Subscription not found. |
ResultUnsupportedVersionError | Consumer not found. Error when an older client/version doesn't support a required feature |