File ExecutionQueueRepositoryImpl.java has 841 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*
 * Copyright © 2014-2017 EntIT Software LLC, a Micro Focus company (L.P.)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

ExecutionRuntimeServices has 97 methods (exceeds 20 allowed). Consider refactoring.

Open

public class ExecutionRuntimeServices implements Serializable {

    private static final long serialVersionUID = 2557429503280678353L;

    protected static final String EXECUTION_PAUSED = "EXECUTION_PAUSED";

File ExecutionServiceImpl.java has 654 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*
 * Copyright © 2014-2017 EntIT Software LLC, a Micro Focus company (L.P.)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

Method equals has a Cognitive Complexity of 62 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;

• Read up
  Read up

QueueAdditionalDetails has 66 methods (exceeds 20 allowed). Consider refactoring.

Open

public class QueueAdditionalDetails implements Serializable {

    private static final long serialVersionUID = 275617756094575753L;

    private String exchangeName;

Method equals has a Cognitive Complexity of 57 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (!(o instanceof ExecutionSummary)) return false;

• Read up
  Read up

Method fillBufferPeriodically has a Cognitive Complexity of 50 (exceeds 5 allowed). Consider refactoring.

Open

    private void fillBufferPeriodically() {
        while (!inShutdown) {
            try {
                boolean workerUp = workerManager.isUp();
                if (!workerUp) {

• Read up
  Read up

File SimpleExecutionRunnable.java has 459 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*
 * Copyright © 2014-2017 EntIT Software LLC, a Micro Focus company (L.P.)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

File ExecutionRuntimeServices.java has 441 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*
 * Copyright © 2014-2017 EntIT Software LLC, a Micro Focus company (L.P.)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

File WorkerNodeServiceImpl.java has 427 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*
 * Copyright © 2014-2017 EntIT Software LLC, a Micro Focus company (L.P.)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

WorkerNode has 45 methods (exceeds 20 allowed). Consider refactoring.

Open

@Entity
@Table(name = "OO_WORKER_NODES")
@DynamicUpdate(value = true)
@SelectBeforeUpdate(value = true)
public class WorkerNode extends AbstractIdentifiable implements Worker {

ExecutionServiceImpl has 44 methods (exceeds 20 allowed). Consider refactoring.

Open

public final class ExecutionServiceImpl implements ExecutionService {

    private static final Logger logger = LogManager.getLogger(ExecutionServiceImpl.class);

    @Autowired

ExecutionSummary has 43 methods (exceeds 20 allowed). Consider refactoring.

Open

public class ExecutionSummary implements Serializable {

    private static final long serialVersionUID = 3895708684033992809L;

    public static final String EMPTY_BRANCH = "EMPTY";

ExecutionMessage has 42 methods (exceeds 20 allowed). Consider refactoring.

Open

public class ExecutionMessage implements Message, Cloneable {

    private static final long serialVersionUID = 3523623124812765964L;

    private static final int JVM_OBJECT_HEADER = 16;

File ExternalPythonExecutorScheduledExecutorTimeout.java has 388 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*
 * Copyright © 2014-2017 EntIT Software LLC, a Micro Focus company (L.P.)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

WorkerNodeServiceImpl has 39 methods (exceeds 20 allowed). Consider refactoring.

Open

public class WorkerNodeServiceImpl implements WorkerNodeService {

    private static final Logger logger = LogManager.getLogger(WorkerNodeServiceImpl.class);

    private static final long MAX_VERSION_GAP_ALLOWED = Long.getLong("max.allowed.version.gap.worker.recovery", 2);

WorkerNodeService has 38 methods (exceeds 20 allowed). Consider refactoring.

Open

public interface WorkerNodeService {

    /**
     * Update the Worker Node entity with the current ack version for the keep alive mechanism
     *

ExecutionQueueRepositoryImpl has 37 methods (exceeds 20 allowed). Consider refactoring.

Open

@SuppressWarnings("FieldCanBeLocal")
public class ExecutionQueueRepositoryImpl implements ExecutionQueueRepository {

    private Logger logger = LogManager.getLogger(getClass());

File DependencyServiceImpl.java has 362 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*
 * Copyright © 2014-2017 EntIT Software LLC, a Micro Focus company (L.P.)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

Method enqueue has a Cognitive Complexity of 30 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    @Transactional
    public void enqueue(List<ExecutionMessage> messages) {
        if (CollectionUtils.isEmpty(messages))
            return;

• Read up
  Read up