in src/exceptions.cc [30:80]
void raiseException(pulsar::Result result) {
switch (result) {
CASE_RESULT(UnknownError)
CASE_RESULT(InvalidConfiguration)
CASE_RESULT(Timeout)
CASE_RESULT(LookupError)
CASE_RESULT(ConnectError)
CASE_RESULT(ReadError)
CASE_RESULT(AuthenticationError)
CASE_RESULT(AuthorizationError)
CASE_RESULT(ErrorGettingAuthenticationData)
CASE_RESULT(BrokerMetadataError)
CASE_RESULT(BrokerPersistenceError)
CASE_RESULT(ChecksumError)
CASE_RESULT(ConsumerBusy)
CASE_RESULT(NotConnected)
CASE_RESULT(AlreadyClosed)
CASE_RESULT(InvalidMessage)
CASE_RESULT(ConsumerNotInitialized)
CASE_RESULT(ProducerNotInitialized)
CASE_RESULT(ProducerBusy)
CASE_RESULT(TooManyLookupRequestException)
CASE_RESULT(InvalidTopicName)
CASE_RESULT(InvalidUrl)
CASE_RESULT(ServiceUnitNotReady)
CASE_RESULT(OperationNotSupported)
CASE_RESULT(ProducerBlockedQuotaExceededError)
CASE_RESULT(ProducerBlockedQuotaExceededException)
CASE_RESULT(ProducerQueueIsFull)
CASE_RESULT(MessageTooBig)
CASE_RESULT(TopicNotFound)
CASE_RESULT(SubscriptionNotFound)
CASE_RESULT(ConsumerNotFound)
CASE_RESULT(UnsupportedVersionError)
CASE_RESULT(TopicTerminated)
CASE_RESULT(CryptoError)
CASE_RESULT(IncompatibleSchema)
CASE_RESULT(ConsumerAssignError)
CASE_RESULT(CumulativeAcknowledgementNotAllowedError)
CASE_RESULT(TransactionCoordinatorNotFoundError)
CASE_RESULT(InvalidTxnStatusError)
CASE_RESULT(NotAllowedError)
CASE_RESULT(TransactionConflict)
CASE_RESULT(TransactionNotFound)
CASE_RESULT(ProducerFenced)
CASE_RESULT(MemoryBufferIsFull)
CASE_RESULT(Interrupted)
default:
return;
}
}