+ @Override
+ public CONTEXT_STATE getState() {
+ return this.state;
+ }
+
+ @Override
+ public void setState(CONTEXT_STATE state) {
+ this.state = state;
+ }
+
+ @Override
+ public ServiceGroupIdentifier getServiceIdentifier() {
+ return this.deviceInfo.getServiceIdentifier();
+ }
+
+ @Override
+ public DeviceInfo getDeviceInfo() {
+ return this.deviceInfo;
+ }
+
+ @Override
+ public void startupClusterServices() throws ExecutionException, InterruptedException {
+ if (!this.shuttingDownStatisticsPolling) {
+ this.statListForCollectingInitialization();
+ this.initialGatherDynamicData();
+ myManager.startScheduling(deviceInfo);
+ }
+ }
+
+ @Override
+ public ListenableFuture<Void> stopClusterServices(boolean deviceDisconnected) {
+ myManager.stopScheduling(deviceInfo);
+ return Futures.immediateFuture(null);
+ }