|
pulsar-client-cpp
|
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::Consumer | friend |
| close() | pulsar::Consumer | |
| closeAsync(ResultCallback callback) | pulsar::Consumer | |
| Consumer() | pulsar::Consumer | |
| ConsumerImpl (defined in pulsar::Consumer) | pulsar::Consumer | friend |
| ConsumerTest (defined in pulsar::Consumer) | pulsar::Consumer | friend |
| getBrokerConsumerStats(BrokerConsumerStats &brokerConsumerStats) | pulsar::Consumer | |
| getBrokerConsumerStatsAsync(BrokerConsumerStatsCallback callback) | pulsar::Consumer | |
| getLastMessageId(MessageId &messageId) | pulsar::Consumer | |
| getLastMessageIdAsync(GetLastMessageIdCallback callback) | pulsar::Consumer | |
| getSubscriptionName() const | pulsar::Consumer | |
| getTopic() const | pulsar::Consumer | |
| isConnected() const | pulsar::Consumer | |
| MultiTopicsConsumerImpl (defined in pulsar::Consumer) | pulsar::Consumer | friend |
| negativeAcknowledge(const Message &message) | pulsar::Consumer | |
| negativeAcknowledge(const MessageId &messageId) | pulsar::Consumer | |
| pauseMessageListener() | pulsar::Consumer | |
| PulsarFriend (defined in pulsar::Consumer) | pulsar::Consumer | friend |
| PulsarWrapper (defined in pulsar::Consumer) | pulsar::Consumer | friend |
| receive(Message &msg) | pulsar::Consumer | |
| receive(TypedMessage< T > &msg, typename TypedMessage< T >::Decoder decoder) (defined in pulsar::Consumer) | pulsar::Consumer | inline |
| receive(Message &msg, int timeoutMs) | pulsar::Consumer | |
| receive(TypedMessage< T > &msg, int timeoutMs, typename TypedMessage< T >::Decoder decoder) (defined in pulsar::Consumer) | pulsar::Consumer | inline |
| 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::Consumer | inline |
| 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::Consumer | virtual |
| seekAsync(uint64_t timestamp, ResultCallback callback) | pulsar::Consumer | virtual |
| unsubscribe() | pulsar::Consumer | |
| unsubscribeAsync(ResultCallback callback) | pulsar::Consumer | |
| ~Consumer()=default (defined in pulsar::Consumer) | pulsar::Consumer | virtual |
1.9.8