apache / activemq - Conditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 23,082 units with 170,627 lines of code in units (78.0% of code).

4 very complex units (765 lines of code)
25 complex units (2,921 lines of code)
297 medium complex units (15,953 lines of code)
806 simple units (23,081 lines of code)
21,950 very simple units (127,907 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
public EncodedMessage transform() in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java	235	68	1
Set checkpointUpdate() in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java	193	60	2
protected void generateFile() in activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CSourcesGenerator.java	221	57	1
protected Boolean compare() in activemq-client/src/main/java/org/apache/activemq/filter/ComparisonExpression.java	116	55	2
final boolean doReconnect() in activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java	144	50	0
public final void acknowledge() in activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java	178	46	2
protected void populateMessage() in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/InboundTransformer.java	125	45	2
protected void serviceRemoteCommand() in activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java	155	42	1
public void oneway() in activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java	116	40	1
ClientImpl.prototype._on_socket_message = function() in activemq-web-demo/src/main/webapp/mqtt/mqttws31.js	138	37	1
public List healthList() in activemq-broker/src/main/java/org/apache/activemq/broker/jmx/HealthView.java	106	37	0
public void configureConnectionFactory() in activemq-tooling/activemq-perf-maven-plugin/src/main/java/org/apache/activemq/tool/spi/ActiveMQPojoSPI.java	72	35	2
WireMessage.prototype.encode = function() in activemq-web-demo/src/main/webapp/mqtt/mqttws31.js	116	34	0
protected boolean matches() in activemq-shiro/src/main/java/org/apache/activemq/shiro/authz/ActiveMQWildcardPermission.java	104	34	2
public void run() in activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java	157	34	0
public void send() in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java	128	33	2
public static Class loadSimpleType() in activemq-client/src/main/java/org/apache/activemq/util/ClassLoadingAwareObjectInputStream.java	44	33	1
private void serviceRemoteConsumerAdvisory() in activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java	116	32	1
private Section convertBody() in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingOutboundTransformer.java	110	31	1
public void send() in activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java	122	31	2
document.getElementsBySelector = function() in activemq-web/src/main/resources/org/apache/activemq/web/behaviour.js	119	30	1
var Client = function() in activemq-web-demo/src/main/webapp/mqtt/mqttws31.js	149	30	3
protected void recoverIndex() in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java	136	29	1
public void add() in activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java	88	29	1
public void baseUpdate() in activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java	83	28	2
private boolean doConnect() in activemq-client/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java	84	28	0
public void removeSubscription() in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java	100	27	3
public boolean iterate() in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java	105	27	0
public void createSender() in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java	126	26	1
protected void doPost() in activemq-web/src/main/java/org/apache/activemq/web/MessageListenerServlet.java	91	25	2
protected void processQueue() in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/CallerBufferingDataFileAppender.java	103	25	0
public void handle() in activemq-broker/src/main/java/org/apache/activemq/util/DefaultIOExceptionHandler.java	97	25	1
protected void handleOption() in activemq-console/src/main/java/org/apache/activemq/console/command/QueryCommand.java	79	25	2
public Connector createConnector() in activemq-http/src/main/java/org/apache/activemq/transport/SecureSocketConnectorFactory.java	75	24	1
public void send() in activemq-broker/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java	78	24	2
public void send() in activemq-broker/src/main/java/org/apache/activemq/plugin/StatisticsBroker.java	131	24	2
public void rollback() in activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java	109	24	0
function caseFoldCharset() in activemq-web-console/src/main/webapp/js/prettify.js	67	23	1
function allowAnywhereFoldCaseAndRenumberGroups() in activemq-web-console/src/main/webapp/js/prettify.js	56	23	1
protected void processQueue() in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java	107	23	0
public void mergeProperties() in activemq-runtime-config/src/main/java/org/apache/activemq/plugin/PropertiesPlaceHolderUtil.java	68	23	3
public void run() in activemq-client/src/main/java/org/apache/activemq/util/ConsumerThread.java	59	23	0
public ActiveMQMessageConsumer() in activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java	100	23	11
public void dispatch() in activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java	77	23	1
private ActiveMQMessage createMessage() in activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/message/JMSMappingInboundTransformer.java	77	22	2
protected void appendHeaders() in activemq-web-console/src/main/java/org/apache/activemq/web/controller/SendMessage.java	62	22	2
public synchronized void start() in activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java	93	22	0
private PendingList doPageInForDispatch() in activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java	101	22	3
protected void setupStaticDestinations() in activemq-broker/src/main/java/org/apache/activemq/network/DurableConduitBridge.java	60	22	0
protected ActiveMQEndpointWorker() in activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java	126	22	2