import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
+import static org.opendaylight.controller.cluster.datastore.DatastoreContextIntrospectorTest.INTROSPECTOR_FACTORY;
+import static org.opendaylight.mdsal.common.api.LogicalDatastoreType.CONFIGURATION;
import java.lang.reflect.Field;
import java.util.HashMap;
public void updateOnConstructionTest() throws Exception {
final Map<String, Object> properties = new HashMap<>();
properties.put("shardTransactionIdleTimeoutInMinutes", 10);
- final DatastoreContext datastoreContext = DatastoreContext.newBuilder().build();
- final DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(datastoreContext);
+ final DatastoreContextIntrospector introspector = INTROSPECTOR_FACTORY.newInstance(CONFIGURATION);
final DatastoreContextPropertiesUpdater updater = new DatastoreContextPropertiesUpdater(introspector,
properties);
public void onUpdateTest() throws Exception {
final Map<String, Object> properties = new HashMap<>();
properties.put("shardTransactionIdleTimeoutInMinutes", 10);
- final DatastoreContext datastoreContext = DatastoreContext.newBuilder().build();
- assertNotNull(datastoreContext);
- final DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(datastoreContext);
+
+ final DatastoreContextIntrospector introspector = INTROSPECTOR_FACTORY.newInstance(CONFIGURATION);
assertNotNull(introspector);
final DatastoreContextPropertiesUpdater updater = new DatastoreContextPropertiesUpdater(introspector,
properties);
final Map<String, Object> properties = new HashMap<>();
properties.put("shardTransactionIdleTimeoutInMinutes", 10);
- final DatastoreContext datastoreContext = DatastoreContext.newBuilder().build();
- final DatastoreContextIntrospector introspector = new DatastoreContextIntrospector(datastoreContext);
+ final DatastoreContextIntrospector introspector = INTROSPECTOR_FACTORY.newInstance(CONFIGURATION);
final DatastoreContextPropertiesUpdater updater = new DatastoreContextPropertiesUpdater(introspector,
properties);
final DummyListenerImpl dummyListener = new DummyListenerImpl();
updater.close();
}
- private Object resolveField(final String name, final Object obj) throws Exception {
+ private static Object resolveField(final String name, final Object obj) throws Exception {
final Field currProps = obj.getClass().getDeclaredField(name);
currProps.setAccessible(true);
return currProps.get(obj);