pulsar-client-phpcpp/src/MessageId.cpp at master · oraoto/pulsar-client-phpcpp · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
#include "MessageId.h"
#include <string>

#define MESSAGE_ID_CLASS_NAME "Pulsar\\MessageId"

MessageId::MessageId(pulsar::MessageId messageId) { this->messageId = messageId; }

static Php::Value earliest()
{
    auto messageId = new MessageId(pulsar::MessageId::earliest());
    return Php::Object(MESSAGE_ID_CLASS_NAME, messageId);
}

static Php::Value latest()
{
    auto messageId = new MessageId(pulsar::MessageId::latest());
    return Php::Object(MESSAGE_ID_CLASS_NAME, messageId);
}

Php::Value MessageId::getTopicName()
{
    return this->messageId.getTopicName();
}

void MessageId::setTopicName(Php::Parameters &params)
{
    return this->messageId.setTopicName(params[0]);
}

Php::Value MessageId::deserialize(Php::Parameters &params)
{
    auto messageId = new MessageId(pulsar::MessageId::deserialize(params[0]));
    return Php::Object(MESSAGE_ID_CLASS_NAME, messageId);
}

Php::Value MessageId::serialize(Php::Parameters &params)
{
    std::string *result = new std::string();
    this->messageId.serialize(*result);
    return result;
}

void registerMessageId(Php::Namespace &pulsarNamespace)
{
    Php::Class<MessageId> messageId("MessageId");
    messageId.method<&MessageId::earliest>("earliest");
    messageId.method<&MessageId::latest>("latest");
    messageId.method<&MessageId::getTopicName>("getTopicName");
    messageId.method<&MessageId::serialize>("serialize");
    messageId.method<&MessageId::deserialize>("deserialize");
}