- public SxpMapperProviderInstance(DataBroker dataBroker, BaseEndpointService endpointService,
- DomainSpecificRegistry registry ) {
+ public SxpMapperProviderInstance(final DataBroker dataBroker,
+ final BaseEndpointService endpointService,
+ final DomainSpecificRegistry registry,
+ final ClusterSingletonServiceProvider clusterSingletonService) {
+ this.dataBroker = Preconditions.checkNotNull(dataBroker);
+ this.endpointService = Preconditions.checkNotNull(endpointService);
+ this.registry = Preconditions.checkNotNull(registry);
+ this.clusterSingletonService = Preconditions.checkNotNull(clusterSingletonService);
+ }
+
+ public void initialize() {
+ LOG.info("Clustering session initiated for {}", this.getClass().getSimpleName());
+ singletonServiceRegistration = clusterSingletonService.registerClusterSingletonService(this);
+ }
+
+ @Override
+ public void instantiateServiceInstance() {
+ LOG.info("Instantiating {}", this.getClass().getSimpleName());