<artifactId>javax.inject</artifactId>
<optional>true</optional>
</dependency>
- <dependency>
- <groupId>org.apache.aries.blueprint</groupId>
- <artifactId>blueprint-maven-plugin-annotation</artifactId>
- <optional>true</optional>
- </dependency>
<dependency>
<groupId>javax.annotation</groupId>
<artifactId>javax.annotation-api</artifactId>
</dependencies>
<build>
<plugins>
- <plugin>
- <groupId>org.apache.aries.blueprint</groupId>
- <artifactId>blueprint-maven-plugin</artifactId>
- <configuration>
- <scanPaths>org.opendaylight.ovsdb.southbound</scanPaths>
- </configuration>
- </plugin>
<plugin>
<groupId>org.apache.felix</groupId>
<artifactId>maven-bundle-plugin</artifactId>
*/
package org.opendaylight.ovsdb.southbound;
-import org.apache.aries.blueprint.annotation.service.Service;
import org.opendaylight.infrautils.diagstatus.DiagStatusService;
import org.opendaylight.infrautils.diagstatus.ServiceDescriptor;
import org.opendaylight.infrautils.diagstatus.ServiceState;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-@Service(classes = ServiceStatusProvider.class)
public class OvsdbDiagStatusProvider implements ServiceStatusProvider {
private static final Logger LOG = LoggerFactory.getLogger(OvsdbDiagStatusProvider.class);
}
- public void reportStatus(ServiceState serviceState, String description) {
+ public void reportStatus(final ServiceState serviceState, final String description) {
LOG.debug("reporting status as {} for {}", serviceState, OVSDB_SERVICE_NAME);
serviceDescriptor = new ServiceDescriptor(OVSDB_SERVICE_NAME, serviceState, description);
diagStatusService.report(serviceDescriptor);
import javax.annotation.PreDestroy;
import javax.inject.Inject;
import javax.inject.Singleton;
-import org.apache.aries.blueprint.annotation.service.Reference;
import org.opendaylight.infrautils.diagstatus.DiagStatusService;
import org.opendaylight.infrautils.diagstatus.ServiceState;
import org.opendaylight.infrautils.ready.SystemReadyMonitor;
private OvsdbUpgradeStateListener ovsdbUpgradeStateListener;
@Inject
- public SouthboundProvider(@Reference final DataBroker dataBroker,
- @Reference final EntityOwnershipService entityOwnershipServiceDependency,
- @Reference final OvsdbConnection ovsdbConnection,
- @Reference final DOMSchemaService schemaService,
- @Reference final BindingNormalizedNodeSerializer bindingNormalizedNodeSerializer,
- @Reference final SystemReadyMonitor systemReadyMonitor,
- @Reference final DiagStatusService diagStatusService,
- @Reference final UpgradeState upgradeState) {
+ public SouthboundProvider(final DataBroker dataBroker,
+ final EntityOwnershipService entityOwnershipServiceDependency,
+ final OvsdbConnection ovsdbConnection,
+ final DOMSchemaService schemaService,
+ final BindingNormalizedNodeSerializer bindingNormalizedNodeSerializer,
+ final SystemReadyMonitor systemReadyMonitor,
+ final DiagStatusService diagStatusService,
+ final UpgradeState upgradeState) {
SouthboundProvider.db = dataBroker;
- this.entityOwnershipService = entityOwnershipServiceDependency;
+ entityOwnershipService = entityOwnershipServiceDependency;
registration = null;
this.ovsdbConnection = ovsdbConnection;
- this.ovsdbStatusProvider = new OvsdbDiagStatusProvider(diagStatusService);
- this.instanceIdentifierCodec = new InstanceIdentifierCodec(schemaService,
- bindingNormalizedNodeSerializer);
+ ovsdbStatusProvider = new OvsdbDiagStatusProvider(diagStatusService);
+ instanceIdentifierCodec = new InstanceIdentifierCodec(schemaService, bindingNormalizedNodeSerializer);
this.systemReadyMonitor = systemReadyMonitor;
this.upgradeState = upgradeState;
LOG.info("SouthboundProvider ovsdbConnectionService Initialized");
public void init() {
LOG.info("SouthboundProvider Session Initiated");
ovsdbStatusProvider.reportStatus(ServiceState.STARTING, "OVSDB initialization in progress");
- this.txInvoker = new TransactionInvokerImpl(db);
+ txInvoker = new TransactionInvokerImpl(db);
cm = new OvsdbConnectionManager(db, txInvoker, entityOwnershipService, ovsdbConnection,
instanceIdentifierCodec, upgradeState);
ovsdbDataTreeChangeListener = new OvsdbDataTreeChangeListener(db, cm, instanceIdentifierCodec);
//Register listener for entityOnwership changes
providerOwnershipChangeListener =
- new SouthboundPluginInstanceEntityOwnershipListener(this,this.entityOwnershipService);
+ new SouthboundPluginInstanceEntityOwnershipListener(this, entityOwnershipService);
//register instance entity to get the ownership of the provider
Entity instanceEntity = new Entity(ENTITY_TYPE, ENTITY_TYPE);
}
public void close() {
- this.listenerRegistration.close();
+ listenerRegistration.close();
}
@Override
<property name="bridgesReconciliationExclusionList" value="${bridge-reconciliation-exclusion-list}"/>
</bean>
+ <reference id="diagStatusService" interface="org.opendaylight.infrautils.diagstatus.DiagStatusService"/>
+ <reference id="systemReadyMonitor" interface="org.opendaylight.infrautils.ready.SystemReadyMonitor"/>
+ <reference id="dataBroker" interface="org.opendaylight.mdsal.binding.api.DataBroker"/>
+ <reference id="bindingNormalizedNodeSerializer" interface="org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer"/>
+ <reference id="domSchemaService" interface="org.opendaylight.mdsal.dom.api.DOMSchemaService"/>
+ <reference id="entityOwnershipService" interface="org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService"/>
+ <reference id="ovsdbConnection" interface="org.opendaylight.ovsdb.lib.OvsdbConnection"/>
+ <reference id="upgradeState" interface="org.opendaylight.serviceutils.upgrade.UpgradeState"/>
+
+ <bean id="southboundProvider" class="org.opendaylight.ovsdb.southbound.SouthboundProvider" init-method="init" destroy-method="close">
+ <argument ref="dataBroker"/>
+ <argument ref="entityOwnershipService"/>
+ <argument ref="ovsdbConnection"/>
+ <argument ref="domSchemaService"/>
+ <argument ref="bindingNormalizedNodeSerializer"/>
+ <argument ref="systemReadyMonitor"/>
+ <argument ref="diagStatusService"/>
+ <argument ref="upgradeState"/>
+ </bean>
+
</blueprint>