artifactbroker/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcClientHandler.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2018 Ericsson. All rights reserved.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.distribution.reception.handling.sdc;
  22
  23 import java.util.Timer;
  24 import java.util.TimerTask;
  25
  26 /**
  27  * This class implements TimerTask for calling life cycle methods of SdcClient iteratively after specified interval
  28  * until the operation is successful.
  29  *
  30  * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com)
  31  */
  32 public class SdcClientHandler extends TimerTask {
  33
  34     private SdcReceptionHandler sdcReceptionHandler;
  35     private SdcClientOperationType operationType;
  36     private Timer timer;
  37
  38     public enum SdcClientOperationType {
  39         START, STOP
  40     }
  41
  42     /**
  43      * Constructs an instance of {@link SdcClientHandler} class.
  44      *
  45      * @param sdcReceptionHandler the sdcReceptionHandler
  46      */
  47     public SdcClientHandler(final SdcReceptionHandler sdcReceptionHandler, final SdcClientOperationType operationType,
  48             final long retryDelay) {
  49         this.sdcReceptionHandler = sdcReceptionHandler;
  50         this.operationType = operationType;
  51         timer = new Timer(false);
  52         timer.scheduleAtFixedRate(this, 0, retryDelay * 1000L);
  53     }
  54
  55     /**
  56      * {@inheritDoc}.
  57      */
  58     @Override
  59     public void run() {
  60         if (SdcClientOperationType.START.equals(operationType)) {
  61             sdcReceptionHandler.initializeSdcClient();
  62             sdcReceptionHandler.startSdcClient();
  63         } else {
  64             sdcReceptionHandler.stopSdcClient();
  65         }
  66     }
  67
  68     /**
  69      * {@inheritDoc}.
  70      */
  71     @Override
  72     public boolean cancel() {
  73         timer.cancel();
  74         return true;
  75     }
  76 }