Skip to content

Commit bbdf4b0

Browse files
committed
Use make_shared instead of constructor
1 parent 8030c20 commit bbdf4b0

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

lib/ConsumerImpl.cc

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -74,19 +74,19 @@ static boost::optional<MessageId> getStartMessageId(const boost::optional<Messag
7474
return startMessageId;
7575
}
7676

77-
static AckGroupingTracker* newAckGroupingTracker(const std::string& topic,
78-
const ConsumerConfiguration& config,
79-
const ClientImplPtr& client) {
77+
static std::shared_ptr<AckGroupingTracker> newAckGroupingTracker(const std::string& topic,
78+
const ConsumerConfiguration& config,
79+
const ClientImplPtr& client) {
8080
if (TopicName::get(topic)->isPersistent()) {
8181
if (config.getAckGroupingTimeMs() > 0) {
82-
return new AckGroupingTrackerEnabled(config.getAckGroupingTimeMs(),
83-
config.getAckGroupingMaxSize(), config.isAckReceiptEnabled(),
84-
client->getIOExecutorProvider()->get());
82+
return std::make_shared<AckGroupingTrackerEnabled>(
83+
config.getAckGroupingTimeMs(), config.getAckGroupingMaxSize(), config.isAckReceiptEnabled(),
84+
client->getIOExecutorProvider()->get());
8585
} else {
86-
return new AckGroupingTrackerDisabled();
86+
return std::make_shared<AckGroupingTrackerDisabled>();
8787
}
8888
} else {
89-
return new AckGroupingTracker();
89+
return std::make_shared<AckGroupingTracker>();
9090
}
9191
}
9292

0 commit comments

Comments
 (0)