Inheritance diagram for pulsar::TypedMessage< T >:

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{};})
T	getValue () const
TypedMessage &	setDecoder (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 MessageId &	getMessageId () 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
int	getRedeliveryCount () const
bool	hasSchemaVersion () const
int64_t	getLongSchemaVersion () const
const std::string &	getSchemaVersion () const
const std::string &	getProducerName () const noexcept
std::optional< const EncryptionContext * >	getEncryptionContext () 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:

Public Types

Public Member Functions