There is no need to box values, use Boolean.TRUE/FALSE as needed.
Change-Id: I2a71106d7281f5b22e5d14f893f5a67c913e49f3
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
private static NetconfCapabilityChange computeDiff(final Set<Capability> added, final Set<Capability> removed) {
final NetconfCapabilityChangeBuilder netconfCapabilityChangeBuilder = new NetconfCapabilityChangeBuilder();
netconfCapabilityChangeBuilder
- .setChangedBy(new ChangedByBuilder().setServerOrUser(new ServerBuilder().setServer(true).build())
- .build());
+ .setChangedBy(new ChangedByBuilder().setServerOrUser(
+ new ServerBuilder().setServer(Boolean.TRUE).build()).build());
netconfCapabilityChangeBuilder.setDeletedCapability(Lists.newArrayList(Collections2
.transform(removed, CAPABILITY_TO_URI)));
netconfCapabilityChangeBuilder.setAddedCapability(Lists.newArrayList(Collections2
@Override
public void onSuccess(final Boolean result) {
if (result == null) {
- sender.tell(false, self);
+ sender.tell(Boolean.FALSE, self);
} else {
sender.tell(result, self);
}
@After
public void tearDown() throws Exception {
deleteCacheDir();
- TestKit.shutdownActorSystem(slaveSystem, Boolean.TRUE);
- TestKit.shutdownActorSystem(masterSystem, Boolean.TRUE);
+ TestKit.shutdownActorSystem(slaveSystem, true);
+ TestKit.shutdownActorSystem(masterSystem, true);
}
private void setupMaster() throws Exception {
@After
public void teardown() {
- TestKit.shutdownActorSystem(system, Boolean.TRUE);
+ TestKit.shutdownActorSystem(system, true);
system = null;
}
@After
public void teardown() {
- TestKit.shutdownActorSystem(slaveSystem, Boolean.TRUE);
- TestKit.shutdownActorSystem(masterSystem, Boolean.TRUE);
+ TestKit.shutdownActorSystem(slaveSystem, true);
+ TestKit.shutdownActorSystem(masterSystem, true);
}
@SuppressWarnings("unchecked")
@AfterClass
public static void staticTearDown() {
- TestKit.shutdownActorSystem(system, Boolean.TRUE);
+ TestKit.shutdownActorSystem(system, true);
}
@Test
@AfterClass
public static void staticTearDown() {
- TestKit.shutdownActorSystem(system, Boolean.TRUE);
+ TestKit.shutdownActorSystem(system, true);
}
}
@Test
public void testExists() {
- when(mockReadTx.exists(STORE, PATH)).thenReturn(Futures.immediateCheckedFuture(true));
+ when(mockReadTx.exists(STORE, PATH)).thenReturn(Futures.immediateCheckedFuture(Boolean.TRUE));
actorRef.tell(new ExistsRequest(STORE, PATH), probe.ref());
verify(mockReadTx).exists(STORE, PATH);
- probe.expectMsg(true);
+ probe.expectMsg(Boolean.TRUE);
}
@Test
@AfterClass
public static void staticTearDown() {
- TestKit.shutdownActorSystem(system, Boolean.TRUE);
+ TestKit.shutdownActorSystem(system, true);
}
@Test
@AfterClass
public static void staticTearDown() {
- TestKit.shutdownActorSystem(system, Boolean.TRUE);
+ TestKit.shutdownActorSystem(system, true);
}
}
@AfterClass
public static void staticTearDown() {
- TestKit.shutdownActorSystem(system, Boolean.TRUE);
+ TestKit.shutdownActorSystem(system, true);
}
private ProxyReadWriteTransaction newSuccessfulProxyTx() {
parser.addArgument("--async-requests")
.type(Boolean.class)
- .setDefault(false)
+ .setDefault(Boolean.FALSE)
.dest("async");
parser.addArgument("--thread-amount")
parser.addArgument("--ssh")
.type(Boolean.class)
- .setDefault(true)
+ .setDefault(Boolean.TRUE)
.help("Whether to use ssh for transport or just pure tcp")
.dest("ssh");
parser.addArgument("--exi")
.type(Boolean.class)
- .setDefault(true)
+ .setDefault(Boolean.TRUE)
.help("Whether to use exi to transport xml content")
.dest("exi");
parser.addArgument("--debug")
.type(Boolean.class)
- .setDefault(false)
+ .setDefault(Boolean.FALSE)
.help("Whether to use debug log level instead of INFO")
.dest("debug");
parser.addArgument("--md-sal")
.type(Boolean.class)
- .setDefault(false)
+ .setDefault(Boolean.FALSE)
.help("Whether to use md-sal datastore instead of default simulated datastore.")
.dest("md-sal");
parser.addArgument("--async-requests")
.type(Boolean.class)
- .setDefault(true)
+ .setDefault(Boolean.TRUE)
.dest("async");
parser.addArgument("--thread-amount")
parser.addArgument("--same-device")
.type(Boolean.class)
- .setDefault(true)
+ .setDefault(Boolean.TRUE)
.help("If true, every thread edits the device at the first port. "
+ "If false, n-th thread edits device at n-th port.")
.dest("same-device");
parser.addArgument("--candidate-datastore")
.type(Boolean.class)
.required(false)
- .setDefault(true)
+ .setDefault(Boolean.TRUE)
.help("Edit candidate or running datastore. Defaults to candidate.")
.dest("candidate-datastore");
parser.addArgument("--debug")
.type(Boolean.class)
- .setDefault(false)
+ .setDefault(Boolean.FALSE)
.help("Whether to use debug log level instead of INFO")
.dest("debug");
parser.addArgument("--legacy-framing")
.type(Boolean.class)
- .setDefault(false)
+ .setDefault(Boolean.FALSE)
.dest("legacy-framing");
parser.addArgument("--exi")
.type(Boolean.class)
- .setDefault(false)
+ .setDefault(Boolean.FALSE)
.dest("exi");
parser.addArgument("--async-requests")
.type(Boolean.class)
- .setDefault(true)
+ .setDefault(Boolean.TRUE)
.dest("async");
parser.addArgument("--msg-timeout")
parser.addArgument("--ssh")
.type(Boolean.class)
- .setDefault(false)
+ .setDefault(Boolean.FALSE)
.dest("ssh");
parser.addArgument("--username")
private static final Logger LOG = LoggerFactory.getLogger(StressClientCallable.class);
- private Parameters params;
+ private final Parameters params;
private final NetconfDeviceCommunicator sessionListener;
private final NetconfClientDispatcherImpl netconfClientDispatcher;
private final NetconfClientConfiguration cfg;
public Boolean call() throws Exception {
executionStrategy.invoke();
netconfClientSession.close();
- return true;
+ return Boolean.TRUE;
}
private static ExecutionStrategy getExecutionStrategy(final Parameters params,