ISubscriptionEntitlementServer2

// Handler
class SubscriptionEntitlementsHandlerAsync
  : public ApmfBase<SubscriptionEntitlementsHandlerAsync, ISubscriptionEntitlementsHandlerAsync> {
public:
  void getAllSubscriptionEntitlements(View<ISubscriptionEntitlementsProvider> provider);
};

...

void SubscriptionEntitlementsHandlerAsync::getAllSubscriptionEntitlements(
  View<ISubscriptionEntitlementsProvider> const provider) {
  provider->addSubscriptionEntitlementChunk(<ADD ENTITLEMENTS>);
  provider->commit();
}

...

// Data refresh handler - store it at least for the duration of data refresh
auto subscriptionEntitlementHandler = Ptr<SubscriptionEntitlementsHandlerAsync>::Make();

...

// Headless service
void MyHeadlessService::onStart(View<IComponentInstance> instance, View<IMessage> message) {
  auto componentInstance = instance
    .TryQueryInterface<apmf::iface::com::amazon::kepler::runtime::IComponentInstance>();

  subscriptionEntitlementServer->setSubscriptionEntitlementsHandlerForComponent(
    subscriptionEntitlementHandler, componentInstance);

  ...

 // Set other handlers here

auto subscriptionEntitlement = serverComponent->makeSubscriptionEntitlementEntryBuilder()
  ->acquisitionTimestamp(<ACQUISITION TIMESTAMP>)
  ->expirationTimestamp(<EXPIRATION TIMESTAMP>)
  ->subscriptionId("subscriptionId")
  ->build();

// Report new subscription entitlement
subscriptionEntitlementServer->reportNewSubscription(subscriptionEntitlement);

auto subscriptionEntitlement = serverComponent->makeSubscriptionEntitlementEntryBuilder()
  ->acquisitionTimestamp(<ACQUISITION TIMESTAMP>)
  ->expirationTimestamp(<EXPIRATION TIMESTAMP>)
  ->subscriptionId("subscriptionId")
  ->build();

// Report removed subscription entitlement
subscriptionEntitlementServer->reportRemovedSubscription(subscriptionEntitlement);