final long stampBeforeGuard,
final long stampAfterGuard,
final NodeId nodeId) {
- return new FutureCallback<Boolean>() {
+ return new FutureCallback<>() {
@Override
public void onSuccess(final Boolean result) {
if (LOG.isDebugEnabled()) {
return resultVehicle;
}
- private FutureCallback<RpcResult<ProcessFlatBatchOutput>> createCounterCallback(final List<Batch> inputBatchBag,
- final int failureIndexLimit,
- final SyncCrudCounters counters) {
- return new FutureCallback<RpcResult<ProcessFlatBatchOutput>>() {
+ private static FutureCallback<RpcResult<ProcessFlatBatchOutput>> createCounterCallback(
+ final List<Batch> inputBatchBag, final int failureIndexLimit, final SyncCrudCounters counters) {
+ return new FutureCallback<>() {
@Override
public void onSuccess(final RpcResult<ProcessFlatBatchOutput> result) {
if (!result.isSuccessful() && result.getResult() != null
public static FutureCallback<RpcResult<Void>> logResultCallback(final NodeId nodeId, final String prefix) {
- return new FutureCallback<RpcResult<Void>>() {
+ return new FutureCallback<>() {
@Override
public void onSuccess(final RpcResult<Void> result) {
if (result != null) {
Assert.assertEquals(6, ReconcileUtil.countTotalUpdated(syncPlan));
}
- private ItemSyncBox<String> createSyncBox(final String pushes, final String updates) {
+ private static ItemSyncBox<String> createSyncBox(final String pushes, final String updates) {
ItemSyncBox<String> syncBox1 = new ItemSyncBox<>();
syncBox1.getItemsToPush().addAll(COMMA_SPLITTER.splitToList(pushes));
for (String orig : COMMA_SPLITTER.splitToList(updates)) {