* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.openflowplugin.applications.frm.impl;
import static org.opendaylight.openflowplugin.applications.frm.util.FrmUtil.getInventoryConfigDataStoreStatus;
import java.util.concurrent.TimeUnit;
import javax.inject.Inject;
import javax.inject.Singleton;
-import org.apache.aries.blueprint.annotation.service.Reference;
import org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener;
import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
@Singleton
public class ListenerRegistrationHelper {
private static final Logger LOG = LoggerFactory.getLogger(ListenerRegistrationHelper.class);
- private final long inventoryCheckTimer = 1;
+ private static final long INVENTORY_CHECK_TIMER = 1;
private final String operational = "OPERATIONAL";
private final ListeningExecutorService listeningExecutorService;
private final DataBroker dataBroker;
@Inject
- public ListenerRegistrationHelper(@Reference final DataBroker dataBroker) {
+ public ListenerRegistrationHelper(final DataBroker dataBroker) {
this.dataBroker = dataBroker;
listeningExecutorService = MoreExecutors.listeningDecorator(Executors.newSingleThreadExecutor(
new ThreadFactoryBuilder()
while (! getInventoryConfigDataStoreStatus().equals(operational)) {
try {
LOG.debug("Retrying for datastore to become operational for listener {}", listener);
- Thread.sleep(inventoryCheckTimer * 1000);
+ Thread.sleep(INVENTORY_CHECK_TIMER * 1000);
} catch (InterruptedException e) {
LOG.info("registerDataTreeChangeListener thread is interrupted");
Thread.currentThread().interrupt();