pulsar-client-cpp
Loading...
Searching...
No Matches
Public Types | Public Member Functions | List of all members
pulsar::TypedMessage< T > Class Template Reference
Inheritance diagram for pulsar::TypedMessage< T >:
pulsar::Message

Public Types

using Decoder = std::function< T(const char *, std::size_t)>
 
- Public Types inherited from pulsar::Message
typedef std::map< std::string, std::string > StringMap
 

Public Member Functions

 TypedMessage (const Message &message, Decoder decoder=[](const char *, std::size_t) { return T{};})
 
getValue () const
 
TypedMessagesetDecoder (Decoder decoder)
 
- Public Member Functions inherited from pulsar::Message
const StringMap & getProperties () const
 
bool hasProperty (const std::string &name) const
 
const std::string & getProperty (const std::string &name) const
 
const void * getData () const
 
std::size_t getLength () const
 
std::string getDataAsString () const
 
KeyValue getKeyValueData () const
 
const MessageIdgetMessageId () const
 
void setMessageId (const MessageId &messageId) const
 
int64_t getIndex () const
 
const std::string & getPartitionKey () const
 
bool hasPartitionKey () const
 
const std::string & getOrderingKey () const
 
bool hasOrderingKey () const
 
uint64_t getPublishTimestamp () const
 
uint64_t getEventTimestamp () const
 
const std::string & getTopicName () const
 
const int getRedeliveryCount () const
 
bool hasSchemaVersion () const
 
int64_t getLongSchemaVersion () const
 
const std::string & getSchemaVersion () const
 
bool operator== (const Message &msg) const
 

Additional Inherited Members

- Protected Types inherited from pulsar::Message
typedef std::shared_ptr< MessageImpl > MessageImplPtr
 
- Protected Member Functions inherited from pulsar::Message
 Message (MessageImplPtr &impl)
 
 Message (const MessageId &messageId, proto::BrokerEntryMetadata &brokerEntryMetadata, proto::MessageMetadata &metadata, SharedBuffer &payload)
 
 Message (const MessageId &messageId, proto::BrokerEntryMetadata &brokerEntryMetadata, proto::MessageMetadata &metadata, SharedBuffer &payload, proto::SingleMessageMetadata &singleMetadata, const std::shared_ptr< std::string > &topicName)
 Used for Batch Messages.
 
- Protected Attributes inherited from pulsar::Message
MessageImplPtr impl_
 

The documentation for this class was generated from the following file: