We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d46a512 commit 1da1260Copy full SHA for 1da1260
1 file changed
lib/c/c_Message.cc
@@ -153,11 +153,7 @@ const char *pulsar_message_get_producer_name(pulsar_message_t *message) {
153
154
const char *pulsar_message_get_replicated_from(pulsar_message_t *message) {
155
const auto replicatedFrom = message->message.getReplicatedFrom();
156
- if (!replicatedFrom) {
157
- return NULL;
158
- }
159
-
160
- return message->message.getReplicatedFrom().value()->c_str();
+ return replicatedFrom ? replicatedFrom.value()->c_str() : nullptr;
161
}
162
163
int pulsar_message_has_null_value(pulsar_message_t *message) { return message->message.hasNullValue(); }
0 commit comments