ext/bindings/consumer.cpp in pulsar-client-2.6.1.pre.beta.1 vs ext/bindings/consumer.cpp in pulsar-client-2.6.1.pre.beta.2
- old
+ new
@@ -80,9 +80,13 @@
.define_value("Exclusive", ConsumerExclusive)
.define_value("Shared", ConsumerShared)
.define_value("Failover", ConsumerFailover)
.define_value("KeyShared", ConsumerKeyShared);
+ define_enum<pulsar::InitialPosition>("InitialPosition", module)
+ .define_value("Latest", InitialPositionLatest)
+ .define_value("Earliest", InitialPositionEarliest);
+
define_class_under<pulsar_rb::ConsumerConfiguration>(module, "ConsumerConfiguration")
.define_constructor(Constructor<pulsar_rb::ConsumerConfiguration>())
.define_method("consumer_type", &ConsumerConfiguration::getConsumerType)
.define_method("consumer_type=", &ConsumerConfiguration::setConsumerType)
// TODO .define_method("schema", &ConsumerConfiguration::getSchema)