pulsar-client-cpp
Loading...
Searching...
No Matches
pulsar::TypedMessageBuilder< T > Class Template Reference
Inheritance diagram for pulsar::TypedMessageBuilder< T >:
pulsar::MessageBuilder

Public Types

using Encoder = std::function<std::string(const T&)>
using Validator = std::function<void(const char* data, size_t)>
Public Types inherited from pulsar::MessageBuilder
typedef std::map< std::string, std::string > StringMap

Public Member Functions

 TypedMessageBuilder (Encoder encoder, Validator validator=[](const char *, std::size_t) {})
TypedMessageBuilder & setValue (const T &value)
Public Member Functions inherited from pulsar::MessageBuilder
Message build ()
MessageBuilder & setContent (const void *data, size_t size)
MessageBuilder & setContent (const std::string &data)
MessageBuilder & setContent (std::string &&data)
MessageBuilder & setContent (const KeyValue &data)
MessageBuilder & setAllocatedContent (void *data, size_t size)
MessageBuilder & setProperty (const std::string &name, const std::string &value)
MessageBuilder & setProperties (const StringMap &properties)
MessageBuilder & setPartitionKey (const std::string &partitionKey)
MessageBuilder & setOrderingKey (const std::string &orderingKey)
MessageBuilder & setDeliverAfter (const std::chrono::milliseconds delay)
MessageBuilder & setDeliverAt (uint64_t deliveryTimestamp)
MessageBuilder & setEventTimestamp (uint64_t eventTimestamp)
MessageBuilder & setSequenceId (int64_t sequenceId)
MessageBuilder & setReplicationClusters (const std::vector< std::string > &clusters)
MessageBuilder & disableReplication (bool flag)
MessageBuilder & create ()

Additional Inherited Members

Protected Member Functions inherited from pulsar::MessageBuilder
const char * data () const
std::size_t size () const

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