*/
package org.opendaylight.netconf.test.tool;
+import static java.util.Objects.requireNonNullElseGet;
+
import com.google.common.collect.Collections2;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
} else {
LOG.info("using OperationsProvider.");
operationProvider = new OperationsProvider(idProvider, transformedCapabilities,
- configuration.getOperationsCreator() != null ? configuration.getOperationsCreator()
- : DefaultOperationsCreator.getDefaultOperationServiceCreator(idProvider.getCurrentSessionId()));
+ requireNonNullElseGet(configuration.getOperationsCreator(),
+ () -> new DefaultOperationsCreator(idProvider.getCurrentSessionId())));
}
-
final NetconfMonitoringOperationServiceFactory monitoringService =
new NetconfMonitoringOperationServiceFactory(
new NetconfMonitoringOperationService(monitoringService1));
import org.opendaylight.netconf.test.tool.rpc.SimulatedUnLock;
public final class DefaultOperationsCreator implements OperationsCreator {
-
private final SimulatedOperationService simulatedOperationService;
- private DefaultOperationsCreator(final long currentSessionId) {
+ public DefaultOperationsCreator(final long currentSessionId) {
simulatedOperationService = new SimulatedOperationService(currentSessionId);
}
@Override
public NetconfOperationService getNetconfOperationService(final Set<Capability> caps,
- final SessionIdProvider idProvider,
- final String netconfSessionIdForReporting) {
+ final SessionIdProvider idProvider, final String netconfSessionIdForReporting) {
return simulatedOperationService;
}
- public static DefaultOperationsCreator getDefaultOperationServiceCreator(final long currentSessionId) {
- return new DefaultOperationsCreator(currentSessionId);
- }
-
static class SimulatedOperationService implements NetconfOperationService {
-
private final long currentSessionId;
SimulatedOperationService(final long currentSessionId) {
* 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.netconf.test.tool.operations;
-import java.util.Collections;
import java.util.Set;
import org.opendaylight.netconf.api.capability.Capability;
import org.opendaylight.netconf.api.monitoring.CapabilityListener;
public class OperationsProvider implements NetconfOperationServiceFactory {
-
private final Set<Capability> caps;
private final SessionIdProvider idProvider;
private final OperationsCreator operationsCreator;
- public OperationsProvider(final SessionIdProvider idProvider,
- final Set<Capability> caps) {
- this(idProvider, caps,
- DefaultOperationsCreator.getDefaultOperationServiceCreator(idProvider.getCurrentSessionId()));
+ public OperationsProvider(final SessionIdProvider idProvider, final Set<Capability> caps) {
+ this(idProvider, caps, new DefaultOperationsCreator(idProvider.getCurrentSessionId()));
}
- public OperationsProvider(final SessionIdProvider idProvider,
- final Set<Capability> caps, OperationsCreator operationsCreator) {
+ public OperationsProvider(final SessionIdProvider idProvider, final Set<Capability> caps,
+ final OperationsCreator operationsCreator) {
this.caps = caps;
this.idProvider = idProvider;
this.operationsCreator = operationsCreator;
}
@Override
- public AutoCloseable registerCapabilityListener(
- final CapabilityListener listener) {
- listener.onCapabilitiesChanged(caps, Collections.emptySet());
- return () -> {
- };
+ public AutoCloseable registerCapabilityListener(final CapabilityListener listener) {
+ listener.onCapabilitiesChanged(caps, Set.of());
+ return () -> { };
}
@Override
- public NetconfOperationService createService(
- final String netconfSessionIdForReporting) {
+ public NetconfOperationService createService(final String netconfSessionIdForReporting) {
return operationsCreator.getNetconfOperationService(caps, idProvider, netconfSessionIdForReporting);
}
}