pulsar-client-cpp
Loading...
Searching...
No Matches
pulsar::Consumer Member List

This is the complete list of members for pulsar::Consumer, including all inherited members.

acknowledge(const Message &message)pulsar::Consumer
acknowledge(const MessageId &messageId)pulsar::Consumer
acknowledge(const MessageIdList &messageIdList)pulsar::Consumer
acknowledgeAsync(const Message &message, ResultCallback callback)pulsar::Consumer
acknowledgeAsync(const MessageId &messageId, ResultCallback callback)pulsar::Consumer
acknowledgeAsync(const MessageIdList &messageIdList, ResultCallback callback)pulsar::Consumer
acknowledgeCumulative(const Message &message)pulsar::Consumer
acknowledgeCumulative(const MessageId &messageId)pulsar::Consumer
acknowledgeCumulativeAsync(const Message &message, ResultCallback callback)pulsar::Consumer
acknowledgeCumulativeAsync(const MessageId &messageId, ResultCallback callback)pulsar::Consumer
batchReceive(Messages &msgs)pulsar::Consumer
batchReceiveAsync(BatchReceiveCallback callback)pulsar::Consumer
ClientImpl (defined in pulsar::Consumer)pulsar::Consumerfriend
close()pulsar::Consumer
closeAsync(ResultCallback callback)pulsar::Consumer
Consumer()pulsar::Consumer
ConsumerImpl (defined in pulsar::Consumer)pulsar::Consumerfriend
ConsumerTest (defined in pulsar::Consumer)pulsar::Consumerfriend
getBrokerConsumerStats(BrokerConsumerStats &brokerConsumerStats)pulsar::Consumer
getBrokerConsumerStatsAsync(BrokerConsumerStatsCallback callback)pulsar::Consumer
getLastMessageId(MessageId &messageId)pulsar::Consumer
getLastMessageIdAsync(GetLastMessageIdCallback callback)pulsar::Consumer
getSubscriptionName() constpulsar::Consumer
getTopic() constpulsar::Consumer
isConnected() constpulsar::Consumer
MultiTopicsConsumerImpl (defined in pulsar::Consumer)pulsar::Consumerfriend
negativeAcknowledge(const Message &message)pulsar::Consumer
negativeAcknowledge(const MessageId &messageId)pulsar::Consumer
pauseMessageListener()pulsar::Consumer
PulsarFriend (defined in pulsar::Consumer)pulsar::Consumerfriend
PulsarWrapper (defined in pulsar::Consumer)pulsar::Consumerfriend
receive(Message &msg)pulsar::Consumer
receive(TypedMessage< T > &msg, typename TypedMessage< T >::Decoder decoder) (defined in pulsar::Consumer)pulsar::Consumerinline
receive(Message &msg, int timeoutMs)pulsar::Consumer
receive(TypedMessage< T > &msg, int timeoutMs, typename TypedMessage< T >::Decoder decoder) (defined in pulsar::Consumer)pulsar::Consumerinline
receiveAsync(ReceiveCallback callback)pulsar::Consumer
receiveAsync(std::function< void(Result result, const TypedMessage< T > &)> callback, typename TypedMessage< T >::Decoder decoder) (defined in pulsar::Consumer)pulsar::Consumerinline
redeliverUnacknowledgedMessages()pulsar::Consumer
resumeMessageListener()pulsar::Consumer
seek(const MessageId &messageId)pulsar::Consumer
seek(uint64_t timestamp)pulsar::Consumer
seekAsync(const MessageId &messageId, ResultCallback callback)pulsar::Consumervirtual
seekAsync(uint64_t timestamp, ResultCallback callback)pulsar::Consumervirtual
unsubscribe()pulsar::Consumer
unsubscribeAsync(ResultCallback callback)pulsar::Consumer
~Consumer()=default (defined in pulsar::Consumer)pulsar::Consumervirtual