ConsumerCryptoFailureAction.h

 
#ifndef CONSUMERCRYPTOFAILUREACTION_H_
#define CONSUMERCRYPTOFAILUREACTION_H_
 
namespace pulsar {
 
enum class ConsumerCryptoFailureAction
{
    FAIL,     // This is the default option to fail consume until crypto succeeds
    DISCARD,  // Message is silently acknowledged and not delivered to the application
    CONSUME   // Deliver the encrypted message to the application. It's the application's
              // responsibility to decrypt the message. If message is also compressed,
              // decompression will fail. If message contain batch messages, client will
              // not be able to retrieve individual messages in the batch
};
 
} /* namespace pulsar */
 
#endif /* CONSUMERCRYPTOFAILUREACTION_H_ */